Flink窗口与水位：乱序与迟到治理

概览

• 水位（Watermark）表示事件时间进度；窗口在水位推进时触发计算；迟到与乱序需治理。
• 通过容忍度与侧输出处理迟到数据。

技术参数（已验证）

• 事件时间：WatermarkStrategy 配置生成水位与乱序容忍；窗口类型滚动/滑动/会话。
• 迟到：allowedLateness 设置容忍；超出进入侧输出进行补偿或审计。
• 触发器与聚合：按窗口触发与增量聚合；结合状态存储与过期。
• 观测：记录水位延迟与迟到比例；处理热点与抖动。
• 精度与成本：容忍度提高精度但增加状态与延迟；需权衡。

实战清单

• 为乱序场景设置合适容忍度与侧输出；按业务需求选择窗口类型。
• 监控水位与迟到指标；在异常时调整策略。
• 将迟到补偿与回放纳入数据治理流程。