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