Re: Queries regarding FlinkCEP

Posted by Dawid Wysakowicz on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Queries-regarding-FlinkCEP-tp13454p13562.html

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).

2017-06-06 16:17 GMT+02:00 Biplob Biswas <[hidden email]>:

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.