Flink極客訓練營Day2

可以不寫出，因爲存在state狀態。 A連接外部系統，將外部數據讀入flink。C連接外部系統，將數據寫入。 存在亂序時，通過插入watermark來使得數據看起來似乎正確，比如插入大小爲3的watermark，就是判斷認爲不會再有比3小的數據傳過來了。 watermark的設計思路可爲eventTime - 5s。 多流watermark都shuffle到同一個處理節點時，爲了保證單調自增，會選

>>阅读原文<<