【Flink】Flink allowedLateness 與 watermark 的區別

1.概述 60-300-022-使用-延遲數據-Flink中allowedLateness詳細介紹 Flink對於亂序數據怎麼辦呢？ 方案就是 watermark。 watermark，直譯爲水位線，就是元素可以遲到多久纔去關閉窗口。例如一個窗口是[0-5),，watermark允許最多延遲3s，那麼一個6s的事件，它的watermark就應該是3，一個7s的watermark是4，這兩個都落在窗

>>阅读原文<<