flink输出中文乱码

（1）首先在/etc/profile.d/my_env.sh中加入下面这行数据

export LANG=zh_CN.UTF-8

（2）其次在flink配置文件中指定编码

[xxx@hadoop102 flink-1.13.6]$ vim conf/flink-conf.yaml

加入下面这行数据

env.java.opts: "-Dfile.encoding=UTF-8"

效果：