Re: KafkaIO Windowing Fn

Thanks Ajioscha\Thomas I will explore on the option to upgrade. Meanwhile here is what observed with the above code in my local Flink Cluster. 1. To start there are 0 records in Kafka 2. Deploy the pipeline. Two records are received in Kafka at time 10:00:00 AM 3. The Pane with 100 records

Re: KafkaIO Windowing Fn

Ah I see, the Flink Runner had quite some updates in 0.2.0-incubating and even more for the upcoming 0.3.0-incubating. On Thu, 1 Sep 2016 at 04:09 Thomas Groh wrote: > In 0.2.0-incubating and beyond we've replaced the DirectPipelineRunner with > the DirectRunner