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.
