Re: Expected behaviour of windows

2017-01-23 Thread Abdul Salam Shaikh
So you can choose between *Fire*, *Purge* and *Fire&Purge*. Seems like >>> selected *Fire* but meant to choose *Fire&Purge*. >>> >>> From what it seems you want a PurgingTrigger. You also didn't state what >>> version of Flink you are using :)

Re: Expected behaviour of windows

2017-01-23 Thread Abdul Salam Shaikh
ou also didn't state what >> version of Flink you are using :) >> >> -- Jonas >> >> >> >> -- >> View this message in context: http://apache-flink-user-maili >> ng-list-archive.2336050.n4.nabble.com/Expected-behaviour- >> of-windows-tp11200p11205.html >> Sent from the Apache Flink User Mailing List archive. mailing list >> archive at Nabble.com. >> > > > > -- > Thanks & Regards, > > *Abdul Salam Shaikh* > > -- Thanks & Regards, *Abdul Salam Shaikh*

Re: Expected behaviour of windows

2017-01-23 Thread Abdul Salam Shaikh
t; > From what it seems you want a PurgingTrigger. You also didn't state what > version of Flink you are using :) > > -- Jonas > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Expected-behaviour-of

Re: Expected behaviour of windows

2017-01-23 Thread Jonas
you want a PurgingTrigger. You also didn't state what version of Flink you are using :) -- Jonas -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Expected-behaviour-of-windows-tp11200p11205.html Sent from the Apache Flink User Mailing Lis

Expected behaviour of windows

2017-01-22 Thread Abdul Salam Shaikh
Hi, I needed some clarity on the behaviour of the windows for my use case. I have defined my stream as follows: env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); * env.setParallelism(1);* DataStream live = env.addSource(new JsonTestSource()); DataStre