java - 如何更改独立 FLINK 集群中单个应用程序的日志记录级别

Question

在独立的flink集群中，集群中运行着许多应用程序。

如您所知，任务管理器和所有应用程序以独立模式运行在单个jvm上，如何更改应用程序的日志记录级别而不影响其他应用程序的日志级别。

在任务管理器的全局级别，可以更改日志记录级别，但它会更改集群中运行的所有应用程序的日志记录，此外，它还需要重新启动所有任务管理器，这在全部。

Answer 1

通常，不可能针对集群类为同一 Flink 集群上运行的不同作业定义不同的日志级别。问题在于集群类在所有作业之间共享，因此使用所有相同的日志级别。不过，您可以做的是通过正确配置 log4j.properties 来为您的作业特定类定义不同的日志级别:

log4j.logger.my.app1=DEBUG
log4j.logger.my.app2=WARN
log4j.logger.my.app3=OFF

使用 log4j 2 时，您还可以为 log4j.properties 文件启用定期刷新间隔。此功能使您可以更改属性文件，并且 log4j 将根据刷新间隔重新配置自身。