在Flink集群中使用Log4j记录问题?
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了在Flink集群中使用Log4j记录问题?相关的知识,希望对你有一定的参考价值。
我有一个程序,其中Log4j用于记录一些信息。当我在IDE / Intellij中测试时,日志文件可以成功生成。而当我提交这个任务来flink独立集群。我在任何工作节点中找不到任何相应的日志文件。
答案
在独立模式下,Flink默认将其日志文件写入FLINK_DIR/log
。 FLINK_DIR
是Flink的主页。您可以通过更改文件FLINK_DIR/conf/log4j.properties
来控制日志记录行为。在那里,您还可以通过log4j.appender.file.file=FILE_PATH
更改记录文件的路径。
另一答案
如果您正在使用纱线群集,则日志将存储在/hadoop/yarn/logs/$application_id$
中
以上是关于在Flink集群中使用Log4j记录问题?的主要内容,如果未能解决你的问题,请参考以下文章
突发!Log4j 爆“核弹级”漏洞,Flink 等项目受影响,提供 Flink 解决方法,赶紧修!...