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:
>
"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