Flink Sink Doris 中文乱码

Kafka -> Flink -> StreamLoad Doris

数据进入 Doris 后,中文数据会显示为 ???


1
-yD env.java.opts="-Dfile.encoding=UTF-8 -Dsun.jnu.encoding=UTF-8"

具体启动命令

1
/opt/cloudera/parcels/FLINK/lib/flink/bin/flink run -yD env.java.opts="-Dfile.encoding=UTF-8 -Dsun.jnu.encoding=UTF-8" -m yarn-cluster -ynm data-real-time-sink-doris -c org.app.SinkDorisApp /opt/realtime/flink-first-1.0-SNAPSHOT.jar