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.
Z pozdrowieniami! / Cheers! Dawid Wysakowicz *Data/Software Engineer* Skype: dawid_wys | Twitter: @OneMoreCoder <http://getindata.com/> 2017-06-20 13:50 GMT+02:00 Biplob Biswas <revolutioni...@gmail.com>: > 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. >
