把任务迁移到flink on yarn上时,出现日志打印的中文出现乱码的情况。 尝试在hadoop集群的yarn上添加编码配置,依旧没法正常输出,观察运行的yarn进程并没有加上对应配置。 后来尝试在flink的conf文件中添加编码配置也没有成功。 最后搜索flink源码发现flink on yarn的任务提交流程中,会读取env.java.opts作为jvm启动配置,最后尝试在提交任务的脚本中添加了 [danger]-yD env.java.opts="-Dflie.encoding=utf-8 -Duser.language"[/danger] 来进行提交,问题就解决了