flink容錯機制

Introduce Apache Flink 提供了可以恢復數據流應用到一致狀態的容錯機制。確保在發生故障時，程序的每條記錄只會作用於狀態一次（exactly-once），當然也可以降級爲至少一次（at-least-once）。 容錯機制通過持續創建分佈式數據流的快照來實現。對於狀態佔用空間小的流應用，這些快照非常輕量，可以高頻率創建而對性能影響很小。流計算應用的狀態保存在一個可配置的環境，如：m

>>阅读原文<<