Re: Flink CEP not emitting timed out events properly

Posted by Biplob Biswas on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-CEP-not-emitting-timed-out-events-properly-tp13794p13862.html

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

Regards,
Biplob