關於EventTime所帶來的問題

在Flink中，EventTime即事件時間，能夠反映事件在某個時間點發生的真實情況，即使在任務重跑情況也能夠被還原，計算某一段時間內的數據，那麼只需要將EventTime範圍的數據聚合計算即可，但是數據在上報、傳輸過程中難免會發生數據延時，進而造成數據亂序，就需要考慮何時去觸發這個計算，Flink使用watermark來衡量當前數據進度，使用時間戳表示，在數據流中隨着數據一起傳輸，當到water

>>阅读原文<<