Flink的watermark原理图

3

w(9)

11

当watermark=窗口结束时间5的时候，触发窗口执行

15

9

7

4

w(3)

w(8)

w(5)

14

16

5

10

2

13

12

WindowsT1-T5

触发执行

6

w(1)

w(10)

1

w(0)

WindowsT5-T10

Watermark原理图

w(6)

2、乱序的Stream的Watermark(指定延迟时间t=2，watermark=maxtime - 2)

w(7)

8

w(2)

当watermark=窗口结束时间的时候，触发窗口执行此时watermark=maxtime=EventTime

w(4)

注意：这里事件4、2、3、6、9、8都是迟到的乱序元素所以不能取它们的EventTime去减t，而是取这之前的最大的一个时间maxEventTime只有maxEventTime才有意义，才有去容忍延迟时间的意义。所以要拿之前maxEventTime不断跟当前的元素的时间做对比，取得真正的maxEventTime

1、有序的Stream的Watermark(t=0，watermark=maxtime-0=maxtime)此时watermark=maxtime=EventTime