Flink Sink Doris 中文乱码
Kafka -> Flink -> StreamLoad Doris
数据进入 Doris 后,中文数据会显示为 ???
Flink 启动命令增加以下命令后解决了中文乱码问题
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 |