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

# Flink窗口与水位：乱序与迟到治理 ## 概览 - 水位（Watermark）表示事件时间进度；窗口在水位推进时触发计算；迟到与乱序需治理。 - 通过容忍度与侧输出处理迟到数据。 ## 技术参数（已验证） - 事件时间：`WatermarkStrategy` 配置生成水位与乱序容忍；窗口类型滚动/滑动/会话。 - 迟到：`allowedLateness` 设置容忍；超出进入侧输出进行补偿或审计。 - 触发器与聚合：按窗口触发与增量聚合；结合状态存储与过期。 - 观测：记录水位延迟与迟到比例；处理热点与抖动。 - 精度与成本：容忍度提高精度但增加状态与延迟；需权衡。 ## 实战清单 - 为乱序场景设置合适容忍度与侧输出；按业务需求选择窗口类型。 - 监控水位与迟到指标；在异常时调整策略。 - 将迟到补偿与回放纳入数据治理流程。