禁用 Apache Flink 日志记录

Question

我使用的是旧版本的Apache Flink，带有Runtime 2.11和Flink Core 1.1.2。由于与其他库的兼容性问题，我无法将其升级到较新的 Apache Flink。我正在尝试禁用运行时上的节点日志记录，以最大程度地减少执行时间。我尝试使用以下代码，但消息显示无限制：

Log4jLoggerAdapter logger = (Log4jLoggerAdapter)LoggerFactory
  .getLogger(JobManager.class);
Field loggerField = Log4jLoggerAdapter.class.getDeclaredField("logger");
loggerField.setAccessible(true);
Logger loggerObject = (Logger)loggerField.get(logger);

Field repoField = Category.class.getDeclaredField("repository");
repoField.setAccessible(true);
LoggerRepository repoObject = (LoggerRepository)repoField.get(loggerObject);
repoObject.setThreshold(Level.OFF);

另外，我想知道是否有办法消除执行计划每个阶段内交换的消息数量。

Answer 1

public static ExecutionEnvironment setupLocalEnvironment() {
     Configuration conf = new Configuration();
      env = new LocalEnvironment(conf);
      env.getConfig().disableSysoutLogging();
      return env;
}

Answer 2

首先，您需要确定您使用的是 slf4j + logback 还是 slf4j + log4j。如果您使用 slf4j + log4j，则通过以下方式禁用 log4j

log4j.rootLogger=OFF

否则，您使用SLF4j +登录，然后通过以下方式禁用登录

<!-- This affects logging for both user code and Flink -->
<root level="OFF">
    <appender-ref ref="file"/>
</root>

Answer 3

你能在你的 Main 函数中试试这个吗：

org.apache.log4j.BasicConfigurator.configure(new NullAppender());

我对你的版本有疑问，但试一试。