【Flink】Flink allowedLateness 与 watermark 的区别

1.概述 60-300-022-使用-延迟数据-Flink中allowedLateness详细介绍 Flink对于乱序数据怎么办呢？ 方案就是 watermark。 watermark，直译为水位线，就是元素可以迟到多久才去关闭窗口。例如一个窗口是[0-5),，watermark允许最多延迟3s，那么一个6s的事件，它的watermark就应该是3，一个7s的watermark是4，这两个都落在窗

>>阅读原文<<