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

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