通过监听本地端口数据，用flink实现流处理，发现端口数据输入中文，flink解析出来乱码，英文没有问题。

端口输入

通过flink项目监听端口

val stream = env.socketTextStream("localhost", 9999)

var sum = 0
val dataSteam = stream.map(x => {
  println("原始数据：" + x)
  println("原始数据：" + new String(x.getBytes("unicode"), 0, x.length, "UTF-8"))
  println("***************")
})

监听结果

原始数据：111
原始数据：��

---

原始数据：\u4e00\u4e8c\u4e09
原始数据：�� \ u 4 e 0 0 \ u

---

原始数据：good
原始数据：�� g

---

原始数据：һ����
原始数据：����

---