Flink| 狀態一致性

      1. 狀態一致性  有狀態的流處理，內部每個算子任務都可以有自己的狀態； 對於流處理器內部（沒有接入sink）來說，所謂的狀態一致性，其實就是我們所說的計算結果要保證準確； 一條數據不應該丟失，也不應該重複計算； 在遇到故障時可以恢復狀態，恢復以後的重新計算，結果應該也是完全正常的； 狀態一致性分類： AT_MOST_ONCE（最多一次），當任務故障時最簡單做法是什麼都不幹，既不恢復丟

>>阅读原文<<