Flink更新于
Watermark 与迟到数据
事件时间、Watermark 策略及迟到事件的处理方法。
事件时间
事件时间是数据实际产生的时间，按事件时间计算才能得到正确的窗口结果。
Watermark 策略
大多数情况使用有界乱序策略即可，乱序上限按数据来源的实际延迟设置。
迟到数据
可以用 allowedLateness 延长窗口，或将迟到事件输出到侧输出流另行处理。
2026 年第四季度开发服务器现接受预约。
查看方案事件时间、Watermark 策略及迟到事件的处理方法。
事件时间是数据实际产生的时间，按事件时间计算才能得到正确的窗口结果。
大多数情况使用有界乱序策略即可，乱序上限按数据来源的实际延迟设置。
可以用 allowedLateness 延长窗口，或将迟到事件输出到侧输出流另行处理。