2020年6月4日
一张图说清楚Flink水印和Lateness
摘要： 真传一句话，假言万卷书。 Flink使用窗口与水印处理乱序问题，使用Latenss处理延迟问题，二者混合使用可以满足很多复杂场景的需求 当Watermark大于窗口结束时间时，会触发窗口内的元素进行计算并缓存起来，随着Watermark增长，在Watermark <窗口结束时间 + Lateness 阅读全文
posted @ 2020-06-04 15:30 码以致用 阅读(349) 评论(0) 推荐(0) 编辑