Flink watermark

在Flink中支持三種不一樣的時間概念：處理時間（processing time）、事件時間（event time）、攝取時間（Ingestion time）。程序員 而水印是衡量event time 進展的一種機制，它一般基於事件時間數據屬性產生，水印做爲數據流的一部分流動並帶有時間戳t，表明該時間點之前的數據都已經到達。網絡 watermark主要是用於處理亂序事件。而正確的處理亂序事件，一般

>>阅读原文<<