Flink Time中Watermaker 水位线机制详解_flink对于水位线后的数据默认抛弃吗-CSDN博客

网站介绍:文章浏览阅读671次。1. Flink Time中水位线的引入简介: 针对前面讲解基于事件时间EventTime窗口分析,默认情况下,如果某个窗口触发计算以后,再来一条窗口内的数据,此时不会计算这条数据,而是直接丢弃。在实际业务数据中,数据乱序到达流处理程序,属于正常现象,原因在于网络延迟到导致数据延迟,无法避免的,所以应该可以允许数据延迟达到(在某个时间范围内),继续计算。比如允许数据最大乱序延迟时间为2秒,那么此时只要符合时间范围乱序时间都会处理,此种机制:Watermark水位线。什么是watermaker机制:_flink对于水位线后的数据默认抛弃吗