Flink流計算編程--Flink中allowedLateness詳細介紹及思考

一、簡介 Flink中藉助watermark以及window和trigger來處理基於event time的亂序問題，那麼如何處理「late element」呢？java 也許有人會問，out-of-order element與late element有什麼區別？不都是一回事麼？web 答案是一回事，都是爲了處理亂序問題而產生的概念。要說區別，能夠總結以下：數據庫 1、經過watermark機制來

>>阅读原文<<