Re: Flink CEP not emitting timed out events properly

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

Hi Biplob,

You are correct that only a higher watermark leads to discarded events.
Are you sure that your custom watermark emitter does not emit a high watermark?
E.g. your partition has elements that are far out-of-order.

In addition, are you sure that your elements are not simply buffered and waiting
for the right watermark?

Kostas

> On Jun 20, 2017, at 2:03 PM, Biplob Biswas <[hidden email]> wrote:
>
> But if that's the case, I don't understand why some of my events are just
> lost .... If the watermark which is used is the smallest ... They either I
> expect a match or I expect a timed out event.
>
> The only way I can imagine my events getting lost is higher watermark than
> the incoming event and thus that event is discarded as too late.
>
>
>
> --
> View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-CEP-not-emitting-timed-out-events-properly-tp13794p13854.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.