Flink理解后期事件与水印

这个 水印延迟 设置Flink在触发窗口之前等待无序事件的时间下限 第一次 .

这个 允许迟到 确定Flink将在窗口状态下保持多长时间。在窗口状态仍然可用时到达的任何延迟事件都将 再次触发窗口 ,使其产生更新的结果。

一旦允许的延迟过期,窗口的状态就会被清除,任何极晚的事件都会被丢弃或发送到侧输出。

如果窗口输出的下游消费者可以像这样处理接收窗口结果的更新(例如,窗口连接到实时仪表板),那么设置相对较短的水印延迟并自由使用允许的延迟可能是有意义的。另一方面,如果在初始结果之后无法利用任何东西,则需要使水印延迟足够大以满足您对准确性/完整性的要求,并将允许的延迟设置为零。