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 13:57:17 GMT
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



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

Mime
View raw message