2022-05-04

flink中Watermark的作用:

1.标识Flink任务的事件时间进度,从而能推动事件事件窗口的触发,计算。

比如一个事件时间窗口,如果没有一个东西去标识其事件事件的进度,那么这个事件时间窗口也就不知道什么时候能够触发了。有了Watermark去标识其事件时间进度,让这个事件窗口知道这个事件时间窗口已经结束了,可以触发计算了。

2.就是解决事件时间窗口的乱序问题(水印时间:对迟到的数据大巴车等一分钟)

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容