DataFlow Scio: не может получить результат строки в качестве локального языка ⇐ JAVA

[Anonymous]

Я не буду для Dataflow, Scala и Apache Beam. Я создал DataFlow, чтобы прочитать результат из текстового файла. И необходимо передать значение функции расшифровки. Он не может показать тайский язык. (Он присутствует как '?), и я заметил, что, если я называю эту функцию перед использованием Scio. это может показать правильно. Я не уверен, что это является основной причиной и как ее исправить. Кто -нибудь может предложить. Большое спасибо. < /P>

Код: Выделить всё

val c = "AAAADCeGmijmVRjgaC6s7UCgaPP0LAhvgvq9NKZc0BaNJs+G01xGy3s="
val msgbytes = decrypt(c).getBytes("UTF-8")
val msg = new String(msgbytes, "UTF-8")
println("msgbefore",msg)
val query = sc.parallelize(uris).map{
row =>
val msgbytesaf = decrypt(c).getBytes("UTF-8")
val msgaf = new String(msgbytesaf, "UTF-8")
println("msgbefore",msg)
println("msgafter",msgaf)
}

Подробнее здесь: https://stackoverflow.com/questions/777 ... l-language