Re: Question about watermark and window

2017-08-28 Thread Tony Wei
Hi Alijoscha, It is very helpful to me to understand the behavior on such scenario. Thank you very much!!! Best Regards, Tony Wei 2017-08-28 20:00 GMT+08:00 Aljoscha Krettek : > Hi Tony, > > I think your analyses are correct. Especially, yes, if you re-read the > data the

Re: Question about watermark and window

2017-08-28 Thread Aljoscha Krettek
Hi Tony, I think your analyses are correct. Especially, yes, if you re-read the data the (ts=3) data should still be considered late if both consumers read with the same speed. If, however, (ts=3) is read before the other consumer reads (ts=8) then it should not be considered late, as you

Question about watermark and window

2017-08-24 Thread Tony Wei
Hi, Recently, I studied about watermark from Flink documents and blogs. I have some question about this scenario below. Suppose there are five clients sending events with different time to the topic on Kafka. Topic has two partitions and five events' timestamp are (ts=1), (ts=2), (ts=3),