CODEWITHSUNDEEP
logginglog4japache-flink
Jun
Jun

Reputation: 639

Logging issue with Log4j in Flink cluster?

I have a program in which Log4j is used to log some information. When I test in the IDE/Intellij, log file could generate successfully. While when I submit this task to flink stand alone cluster. I couldn't find any corresponding log file in any worker node.

Upvotes: 4

Views: 3163

Answers (2)

SunSen
SunSen

Reputation: 1

If you are using yarn cluster,then the log is stored at /hadoop/yarn/logs/$application_id$

Upvotes: -1

Till Rohrmann
Till Rohrmann

Reputation: 13346

In standalone mode, Flink writes its log files to FLINK_DIR/log per default. FLINK_DIR is the home directory of Flink. You can control the logging behaviour by changing the file FLINK_DIR/conf/log4j.properties. There you can also change the path via log4j.appender.file.file=FILE_PATH to which the logging files are written.

Upvotes: 3

Related Questions