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-tp13794p13857.html
Hi Kostas,
I have out-of-orderness of around 5 seconds from what I have observed but that too from events coming from a different topic. The initial topic doesn't have out-of-order events still I have added a generous time bound of 20 seconds. Still, I will try for a higher number just in order to check a bit more.
The second problem you suggested sounds more interesting because when I print my events which have been ingested I see all the events. It's just that those events are neither generating a match nor are generating an anomaly which felt a bit weird for me.
In what cases the elements could be buffered and waiting forever? I expected that even if they are buffered when the timeout happens I would get all the events which were waiting for a match, provided the watermark is reset and that I am doing by setting the autoWatermarkinterval and increasing the watermark when there are no new events and after every 10-second system time.
Regards,
Biplob