Re: Flink CEP not emitting timed out events properly

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

It is possible that two Watermarks will be passed through the Stream, but at an operator that has more than one input streams(in your case from different topics and partitions) the smallest Watermark is considered valid and passed downstream.

2017-06-20 13:50 GMT+02:00 Biplob Biswas <[hidden email]>:

Hi dawid,

First of all congratulations on being a Flink committer, saw your tweet in
the morning.

Now regarding that link, that talks about multiple partitions for a single
topic, here I am talking about multiple topics each having different number
of partitions.

I tried adding tinestampextractor at the kafkasource, but
I still observe different watermarks when I am logging the current watermark
timestamp.

If I expect the same behaviour shouldnt there be only one value for a
watermark?

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

Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.