Flink基於EventTime和WaterMark處理亂序事件和晚到的數據(三)

在實際的業務中,咱們常常會遇到數據遲到的狀況,這個時候基於窗口進行計算的結果就不對了,Flink中watermark就是爲了解決這個問題的,理解watermark以前,先來講一下flink中的三個與流數據相關的概念,ProcessTime、EventTime、IngestionTime,否則很難理解watermark是怎麼回事.java 咱們先來看一下官網給出的一張圖,很是形象地展現了Proces

>>阅读原文<<