Sorry I have not responded earlier. Did you try input like this?: > 1,a,1,0 > 5,a,3,2 > 6,a,2,1 > 8,b,5,1 > 12,b,4,6 > 12,b,70000,6
In response to your PS, in this example no events are late(in regards to maxOutOfOrderness). If after the last event there was an event like (12,b, 9999, 6) it would be discarded, because 9999 < 70000 - 60000(=60s). Z pozdrowieniami! / Cheers! Dawid Wysakowicz *Data/Software Engineer* Skype: dawid_wys | Twitter: @OneMoreCoder <http://getindata.com/> 2017-06-06 16:17 GMT+02:00 Biplob Biswas <revolutioni...@gmail.com>: > Hi Dawid, > > What you wrote is exactly correct, it wouldn't generate a new waatermark > (and subsequently throw events) unless maxOutOfOrderness time is elapsed. > Thus, I was expecting for alerts to be raised as the stream was out of > order > but not out of maxOutOfOrderness. > > Nevertheless I tried your example and the result is the same, I get nothing > as output except the events themselves which I see with events.print() > > PS: BTW, shouldn't your example generate nothing because its beyond the > maxOutOfOrderness and Flink would simply discard these messages. > > Regards, > Biplob > > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Queries-regarding-FlinkCEP- > tp13454p13523.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
