如何在Flink Run命令行传递自定义Log4j配置并覆盖默认配置？

我懂你现在的困扰——你已经尝试通过-yD env.java.opts指定了自定义Log4j配置，而且JobManager的日志确实已经用上了新配置，但Flink客户端的日志还是死守着conf/log4j.properties里的默认设置，完全不受影响对吧？

问题根源 #

你用的-yD参数是用来配置YARN集群上运行的Flink进程（包括JobManager和TaskManager）的JVM参数，而Flink客户端是在你本地机器上运行的独立进程，它的JVM参数根本不会被-yD这个选项覆盖，所以客户端自然还是用默认的Log4j配置。

解决方案 #

这里有两种实用的解决办法，你可以根据自己的需求选：

• 临时生效（单次任务提交）：直接在启动Flink客户端时，通过JAVA_OPTS环境变量传入自定义Log4j配置参数，命令格式如下：

  JAVA_OPTS="-Dlog4j.configuration=file:///path/to/log4j.properties" ./bin/flink run -m yarn-cluster -yn 1 ./examples/batch/WordCount.jar
  

  这样客户端进程启动时就会加载你指定的配置文件，日志输出就会符合你的预期了。

• 全局生效（所有客户端启动）：如果你每次提交任务都需要用同一个自定义Log4j配置，可以修改Flink的客户端启动脚本bin/flink。找到脚本里设置JAVA_OPTS的位置，把-Dlog4j.configuration=file:///path/to/log4j.properties添加进去，这样以后所有通过这个脚本启动的客户端都会自动加载你的自定义配置。

小提示 #

• 确保你的自定义Log4j配置文件路径是绝对路径，避免客户端进程找不到文件的问题；
• 如果你用的是Log4j 2.x，参数需要改成-Dlog4j.configurationFile=file:///path/to/log4j2.properties，注意区分版本差异。

内容的提问来源于stack exchange，提问作者MrunmayeeJog