Hi, the web interface is a good idea for checking if everything is working as expected. However in this case I expect the counts for the task be 0 because the source and sink are chained together into one task (upcoming Flink releases will fix this behavior).
I assume the "StringLogSink" is logging all incoming events. How do you do that? Using slf4j ? our by System.out.println? I'm asking to make sure you're looking at the right place to capture the output. It will be at the YARN containers. Regards, Robert On Tue, Apr 26, 2016 at 8:34 PM, Dominik Choma <dominik.ch...@gmail.com> wrote: > Hi, > > You can check if any messages are going through dataflow on flink web > dashboard > https://flink.apache.org/img/blog/new-dashboard-screenshot.png > > > > Dominik Choma > > Wiadomość napisana przez Conlin, Joshua [USA] <conlin_jos...@bah.com> w > dniu 26 kwi 2016, o godz. 20:16: > > re messages being sent to Kafka on that topic, I just never see anything > in Flink. Any help/insight you could provide would be greatly > appreciated. If it makes a difference this is running on YARN. Also, > here’s what I see in the logs: > > >
