Flink的watermark原理图
2021-12-15 11:11:03 24 举报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
收藏
0 条评论
下一页
为你推荐
查看更多
