Flink 详解（二）：水位线 Watermark 与乱序、迟到数据处理

Flink 的水位线机制基于事件时间驱动窗口计算，解决分布式系统时间偏差导致的统计不准确。对于有序数据（事件时间单调递增），使用单调时间戳策略；无序数据则通过 `forBoundedOutOfOrderness` 设置最大乱序延迟，容忍部分迟到数据。用户可自定义周期型或定点型水位线生成策略，满足特定业务触发条件。迟到数据通过两层兜底：`allowedLateness` 允许窗口结束后二次计算，`sideOutputLateData` 将完全迟到的数据放入侧输出流单独处理。合理搭配乱序延迟、允许迟到时间和侧输出流，可平衡数据完整性与计算延迟，灵活应对实时场景中的时间相关挑战。