flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dawid Wysakowicz <wysakowicz.da...@gmail.com>
Subject Re: Flink CEP not emitting timed out events properly
Date Tue, 20 Jun 2017 12:15:22 GMT
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


2017-06-20 13:50 GMT+02:00 Biplob Biswas <revolutionisme@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.

View raw message