Flink 集群中 Log4j 的日志记录问题？
Logging issue with Log4j in Flink cluster?
我有一个程序，其中使用 Log4j 来记录一些信息。当我在 IDE/Intellij 中测试时，日志文件可以成功生成。当我将此任务提交给 flink 独立集群时。我在任何工作节点中都找不到任何相应的日志文件。
在独立模式下，Flink 默认将其日志文件写入 FLINK_DIR/log。 FLINK_DIR是Flink的家目录。您可以通过更改文件 FLINK_DIR/conf/log4j.properties 来控制日志记录行为。您还可以通过 log4j.appender.file.file=FILE_PATH 更改写入日志文件的路径。
如果你使用的是yarn cluster，那么日志存储在/hadoop/yarn/logs/$application_id$
我有一个程序，其中使用 Log4j 来记录一些信息。当我在 IDE/Intellij 中测试时，日志文件可以成功生成。当我将此任务提交给 flink 独立集群时。我在任何工作节点中都找不到任何相应的日志文件。
在独立模式下，Flink 默认将其日志文件写入 FLINK_DIR/log。 FLINK_DIR是Flink的家目录。您可以通过更改文件 FLINK_DIR/conf/log4j.properties 来控制日志记录行为。您还可以通过 log4j.appender.file.file=FILE_PATH 更改写入日志文件的路径。
如果你使用的是yarn cluster，那么日志存储在/hadoop/yarn/logs/$application_id$