Flink流式框架的狀態一致性

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

>>阅读原文<<