flink中Watermark的作用:
1.标识Flink任务的事件时间进度,从而能推动事件事件窗口的触发,计算。
比如一个事件时间窗口,如果没有一个东西去标识其事件事件的进度,那么这个事件时间窗口也就不知道什么时候能够触发了。有了Watermark去标识其事件时间进度,让这个事件窗口知道这个事件时间窗口已经结束了,可以触发计算了。
2.就是解决事件时间窗口的乱序问题(水印时间:对迟到的数据大巴车等一分钟)
flink中Watermark的作用:
1.标识Flink任务的事件时间进度,从而能推动事件事件窗口的触发,计算。
比如一个事件时间窗口,如果没有一个东西去标识其事件事件的进度,那么这个事件时间窗口也就不知道什么时候能够触发了。有了Watermark去标识其事件时间进度,让这个事件窗口知道这个事件时间窗口已经结束了,可以触发计算了。
2.就是解决事件时间窗口的乱序问题(水印时间:对迟到的数据大巴车等一分钟)