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

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