我有一个程序，其中log4j用于记录一些信息。在ide/intellij中测试时，日志文件可以成功生成。当我把这个任务提交给flink独立集群时。我在任何工作节点中都找不到任何相应的日志文件。
uurv41yg1#
在独立模式下，flink将其日志文件写入 FLINK_DIR/log 按默认值。 FLINK_DIR 是flink的主目录。您可以通过更改文件来控制日志记录行为 FLINK_DIR/conf/log4j.properties . 在那里，您还可以通过 log4j.appender.file.file=FILE_PATH 将日志文件写入其中。
FLINK_DIR/log
FLINK_DIR
FLINK_DIR/conf/log4j.properties
log4j.appender.file.file=FILE_PATH
htzpubme2#
如果您使用的是Yarn簇，则日志存储在 /hadoop/yarn/logs/$application_id$
/hadoop/yarn/logs/$application_id$
2条答案
按热度按时间uurv41yg1#
在独立模式下，flink将其日志文件写入
FLINK_DIR/log按默认值。FLINK_DIR是flink的主目录。您可以通过更改文件来控制日志记录行为FLINK_DIR/conf/log4j.properties. 在那里，您还可以通过log4j.appender.file.file=FILE_PATH将日志文件写入其中。htzpubme2#
如果您使用的是Yarn簇，则日志存储在
/hadoop/yarn/logs/$application_id$