flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Biplob Biswas <revolutioni...@gmail.com>
Subject Re: Flink CEP not emitting timed out events properly
Date Tue, 20 Jun 2017 14:55:02 GMT
I know that there wouldn't be a scenario where the first event type(coming
from topic t1) would be coming with a timestamp higher than the current
watermark. Although I am still investigating whether the other events from
other topics (specifically t3 and t4) are arriving after the watermark
update process.
But in that case, I at least expect timeout rather than matches. I am not
getting the number of events equal to the number of events ingested from t1
(it's the first event in my CEP engine, so it starts the pattern).

I would try with a huge delay to increment the watermark and that too in
smaller intervals, Hopefully, I would get the desired results.

Would update whatever I get by tomorrow. 

Thanks a lot for the assistance Kostas. :) 


View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-not-emitting-timed-out-events-properly-tp13794p13862.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

View raw message