Watermark（水位線）

數據產生時是有序的，但是考慮到網絡延遲，它們到達Flink時，有可能時亂序的，先發生的事件延時到達。為了解決事件延時到達（或者說減少延時數據對計算結果的影響），有了watermark機制。 wate ...

flink架構，任務、子任務、算子概念

數據來源：https://blog.csdn.net/zhaocuit/article/details/106588758 flink架構Job Managers（master）：作業管理器， ...