Hello, everyone.
I'm learning Flink but still not sure if I realise the topic of watermark
mechanism.
That is a simple common example of pipeline with event-time mode:
<
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/file/t2998/photo_2021-02-27_23-28-29.jpg>
I want to use strategy
*WatermarkStrategy.forBoundedOutOfOrderness(Duration.ofSecond(6))* in my
code. Does it mean that this strategy is working by formula:
*max(event_time) - 6 sec. = new watermark?*
So there are next steps:
0. At first we have w(0) and no input events
1. Get 4. 4 is new max. -> 4-6 < 0 -> still w(0)
2. Get 2. 2 < 4 -> 4 is max -> still w(0)
3. Get 11. 11 > 4 -> 11 is new max -> 11-6 = 5 -> new watermark w(5)
4. Get 7. 11 is max. -> still w(5)
5. Get 9. 11 is max. -> still w(5)
6. Get 15 15 > 11 -> 15 is new max -> 15-6 = 9 -> new watermark w(9)
Am I right?
Thanks,
Yuri L.
--
Sent from:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Locked
