在Flink集群中使用Log4j记录问题?

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了在Flink集群中使用Log4j记录问题?相关的知识,希望对你有一定的参考价值。

我有一个程序,其中Log4j用于记录一些信息。当我在IDE / Intellij中测试时,日志文件可以成功生成。而当我提交这个任务来flink独立集群。我在任何工作节点中找不到任何相应的日志文件。

答案

在独立模式下,Flink默认将其日志文件写入FLINK_DIR/logFLINK_DIR是Flink的主页。您可以通过更改文件FLINK_DIR/conf/log4j.properties来控制日志记录行为。在那里,您还可以通过log4j.appender.file.file=FILE_PATH更改记录文件的路径。

另一答案

如果您正在使用纱线群集,则日志将存储在/hadoop/yarn/logs/$application_id$

以上是关于在Flink集群中使用Log4j记录问题?的主要内容,如果未能解决你的问题,请参考以下文章

Flink高可用集群搭建

Apache Flink 生产集群详情

如何使用Apache Flink阅读Cassandra?

突发!Log4j 爆“核弹级”漏洞,Flink 等项目受影响,提供 Flink 解决方法,赶紧修!...

Flink等多组件受影响,Apache Log4j曝史诗级漏洞

Flink等多组件受影响,Apache Log4j曝史诗级漏洞