Flink的容錯機制

1 狀態一致性       當在分佈式系統中引入狀態時，自然引入了一致性問題。一致性實際上是「正確性級別」的另一種說法，也就是說在成功處理故障並恢復之後得到的結果，與沒有發生任何故障時得到的結果相比，前者到底有多正確？舉例來說，假設要對最近一小時登錄的用戶計數。在系.統經歷故障之後，計數結果是多少？如果有偏差，是有漏掉的計數還是重複計數？ 1.1 基本概念       有狀態的流處理，內部算子任務

>>阅读原文<<