Re: Consuming Messages from Kafka

2016-04-26 Thread Dominik Choma
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 <https://flink.apache.org/img/blog/new-dashboard-screenshot.png> Dominik Choma > Wiadomość napisana przez Conlin, Joshua [USA] w dniu

Re: Understanding Sliding Windows

2016-04-26 Thread Dominik Choma
Piyush, You created sliding window witch is triggered every 10 seconds Flink fires up this window every 10 seconds, without waiting at 5 min buffer to be filled up It seems to me that first argument is rather "maximum data buffer retention" than " the initial threshold" Dominik Dominik 2016-0