I have a program in which Log4j is used to record some information. When I test in IDE/Intellij, the log file can be generated successfully. And when I submit this task to flink independent cluster . I can’t find any corresponding log files in any working node.
In standalone mode, Flink defaults to Its log file is written to FLINK_DIR/log. FLINK_DIR is the home directory of Flink. You can control the logging behavior by changing the file FLINK_DIR/conf/log4j.properties. There, you can also write log4j.appender to the log file. file.file = FILE_PATH change the path.
I have a program in which Log4j is used to log some information. When I test in IDE/Intellij, the log file can be successfully generated. And when I submitted this task to a flink standalone cluster. I cannot find any corresponding log files in any worker nodes.
In standalone mode, Flink writes its log files by default Enter FLINK_DIR/log. FLINK_DIR is the home directory of Flink. You can control the logging behavior by changing the file FLINK_DIR/conf/log4j.properties. There, you can also write to the log file by log4j.appender.file.file= FILE_PATH change path.