如何在运行时更改apache flink的日志级别

Question

是否可以在运行时更改flink框架的日志级别？什么时候flink集群已经在运行？我参考了下面的文件，没有提到它。

https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/logging.html

Answer 1

在程序代码中，Flink使用SLF4J进行日志记录，并支持log4j ( Flink>= 1.11的log4j2，log4j < 1.11)和Logback作为底层日志记录框架，可以通过各自的.properties文件自由配置。

据我所知，SLF4J本身不支持在运行时更改日志级别，在Flink本身中，我看不到任何与底层日志框架相关的自定义代码，如log4j或logback，它们会通过某种机制(如REST API )更改日志级别。

也就是说，日志框架本身可能允许某种机制在运行时更改日志级别。在一个简短的谷歌搜索中，我发现例如log4j包含了一些机制，例如通过使用文件监视器和在运行时重新加载日志属性文件，参见例如：Dynamically Changing log4j log level当然，您需要自己构建工具，即找出您的TaskManagers和JobManagers正在运行的位置，拥有它们的工作目录，并相应地提供/编辑文件。

结论:我建议您使用保存点停止作业，更改日志记录属性，然后重新启动作业。这可能是更简单的方法..