Re: [External] Re: Consuming Messages from Kafka

2016-04-26 Thread Robert Metzger
Hi Josh, The JobManager log won't contain this output. Check out these slides I did a while ago, they explain how you can retrieve the logs from the TaskManagers: http://www.slideshare.net/robertmetzger1/apache-flink-hands-on#14 On Tue, Apr 26, 2016 at 9:41 PM, Conlin, Joshua [USA] wrote: >

Re: [External] Re: Consuming Messages from Kafka

2016-04-26 Thread Conlin, Joshua [USA]
"StringLogSink" just looks like: System.out.println(msg); LOG.info("Logging message: " + msg); And LOG is from slf4j. In the Flink UI that is running on Yarn, I see no counts, nor log statements or stdout under JobManager. It seems to make no difference if I submit the job through yarn via