在FlinkSQL中如何处理迟到数据？

　　1、水位线（Watermarks）： 水位线是一种特殊的时间戳，用来标记在这个时间点之前的数据都已经到达。通过定义水位线的延迟时间，Flink可以容忍数据的迟到。迟到数据在水位线延迟时间内到达时，仍然可以被正常处理。

　　2、侧输出流（Side Outputs）： 对于超出水位线延迟时间仍然迟到的数据，可以通过侧输出流的方式进行处理。侧输出流允许将这部分迟到的数据分流到另一个流中，进行特殊处理，如重新聚合或更新结果等。

很赞哦！

python编程网提示：转载请注明来源www.python66.com。
有宝贵意见可添加站长微信(底部)，获取技术资料请到公众号(底部)。同行交流请加群