Flink 事件时间与水位线深度实践（2025）

# Flink 事件时间与水位线深度实践（2025） 事件时间驱动窗口是 Flink 的核心能力。本文聚焦乱序与迟到数据的工程实践。 ## 一、事件时间与水位线 - 事件时间：以事件携带时间戳驱动计算，避免处理时间偏差。 - 水位线（Watermark）：标示低于某时间的事件基本到齐，推进窗口触发。 ## 二、乱序与迟到数据 - 乱序容忍：设置最大乱序延迟，缓解事件到达无序。 - 迟到处理：为迟到事件配置侧输出，避免污染主结果。 ## 三、窗口与触发器 - 窗口类型：滚动/滑动/会话；按业务选择与参数校准。 - 触发器与清理：触发条件与过期清理防止状态膨胀。 ## 四、参数与观测 - 水位线策略：定期/按分区/对齐策略影响准确性与延迟。 - 观测：采集窗口延迟、迟到率与丢弃率，迭代优化。 ## 注意事项 - 参数以真实乱序分布与 SLA 校准；迟到策略与侧输出需与下游协议一致。 - 分类、关键词与描述与正文一致，便于统一管理与发布。