flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Biplob Biswas <revolutioni...@gmail.com>
Subject Re: Queries regarding FlinkCEP
Date Tue, 06 Jun 2017 14:17:18 GMT
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.


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.

View raw message