java - 如何使用服务器上的 -Dlog4j.configuration=file :/path/to/log4j. 属性运行我的 flink 作业

Question

我已将我的 log4j.properties 保存在服务器上。我想在服务器上运行我的 flink 作业时访问该属性文件我不知道如何使用“-Dlog4j.configuration=file:/path/to/log4j.properties”命令来运行 flink 作业

运行 flink 作业的命令是 - bin/flink run/opt/Flink/50.jar我应该在我的命令中的哪里添加“-Dlog4j.configuration=file:/path/to/log4j.properties”

属性文件包含-

log4j.rootLogger =DEBUG, FILE, FILE2

log4j.appender.FILE =org.apache.log4j.FileAppender

log4j.appender.FILE.File=${my.log1}

log4j.appender.FILE.layout = org.apache.log4j.PatternLayout

log4j.appender.FILE.layout.ConversionPattern =%d{ISO8601} %-5p %c ~ %m%n

log4j.appender.FILE.Threshold = ERROR

log4j.appender.FILE2 = org.apache.log4j.FileAppender

log4j.appender.FILE2.File=${my.log}

log4j.appender.FILE2.layout =org.apache.log4j.PatternLayout

log4j.appender.FILE2.layout.ConversionPattern =%d{ISO8601} %-5p %c ~ %m%n

log4j.appender.FILE2.Threshold = ERROR

Answer 1

如果您使用的是 flink“独立集群”，您希望将此条目添加到您的 flink-conf.yaml 中:

env.java.opts: -Dlog4j.configuration=file:/path/to/log4j.properties

您还可以为 taskmanager 和 jobmanager 设置不同的配置:

env.java.opts.taskmanager: -Dlog4j.configuration=file:/path/to/log4j.properties
env.java.opts.jobmanager: -Dlog4j.configuration=file:/path/to/log4j.properties

这不是“每个作业”的配置基础，而是适用于所有作业。

参见 the documentation here