Flink WaterMark（水位線）分佈式執行理解

背景         WaterMark (水印) 本質上是一個時間戳。當Flink中的運算符接收到水印時，它明白（假設）它不會看到比該時間戳更早的消息。所以，在「EventTime」中，水印也能夠被認爲是一種告訴Flink它有多遠的一種方式，WaterMark還能夠用來實現時間延遲。編程        本文主要涉及水印在單線程和分佈式狀況下的理解，基礎知識和應用請看：Flink watermar

>>阅读原文<<