Skip to content

Instantly share code, notes, and snippets.

@knub
Last active Aug 29, 2015
Embed
What would you like to do?
Flink logging output.
14.04.2015 - 18:53 - Starting program with parameters xyz. # This is my personal logging with my configured style, see log4j.xml
14.04.2015 - 18:53 - Slf4jLogger started # That's not from me, must be somewhere in Flink.
04/14/2015 18:53:37 Job execution switched to status RUNNING. # Now the logging style's changed, and Flink logs alot about the progress.
[ .. more stuff from Flink .. ]
When I am setting the log level to INFO for Flink, I even get mixed logging output like:
[ .. ]
14.04.2015 - 18:59 - Deploying MapPartition (Wiki-Pages) (1/1) (attempt #0) to localhost
14.04.2015 - 18:59 - Deploying MapPartition (Wiki-Pages) (1/1) (attempt #0) to localhost
04/14/2015 18:59:30 MapPartition (Wiki-Pages)(1/1) switched to SCHEDULED
04/14/2015 18:59:30 MapPartition (Wiki-Pages)(1/1) switched to DEPLOYING
[ .. ]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment