問題定位:Flink水位線不觸發問題

Flink水位線不觸發問題 窗口計算時遇到好幾回水位線不觸發的狀況,簡單總結下。html 首先,介紹下Flink的事件時間(EventTime)和水位線(Watermarks)的概念。java 1、處理時間 若是要構造一個實時的流式應用,或早或晚都會接觸到EventTime這個概念。現實場景中也會遇到消息亂序到達,這裏會介紹到爲何須要事件時間和如何去處理亂序到達的數據。 ProcessingTim
相關文章
相關標籤/搜索