Tutorial by Examples

Add the slf4j dependency to your pom.xml: <properties> <slf4j.version>1.7.21</slf4j.version> </properties> <!-- ... --> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version&gt...

Local mode In local mode, for example when running your application from an IDE, you can configure log4j as usual, i.e. by making a log4j.properties available in the classpath. An easy way in maven is to create log4j.properties in the src/main/resources folder. Here is an example: log4j.rootLogger...

In case you need different settings for your various applications, there is (as of Flink 1.2) no easy way to do that. If you use the one-yarn-cluster-per-job mode of flink (i.e. you launch your scripts with: flink run -m yarn-cluster ...), here is a workaround : create a conf directory somewhe...

Yarn does not by default aggregate logs before an application finishes, which can be problematic with streaming jobs that don't even terminate. A workaround is to use rsyslog, which is available on most linux machines. First, allow incoming udp requests by uncommenting the following lines in /etc/...