實時流處理系統容錯機制（二）：Apache Flink 基於State的異步容錯機制

1. Introduce         Apache Flink 提供了能夠恢復數據流應用到一致狀態的容錯機制。確保在發生故障時，程序的每條記錄只會做用於狀態一次（exactly-once），固然也能夠降級爲至少一次（at-least-once）。算法         容錯機制經過持續建立分佈式數據流的快照來實現。對於狀態佔用空間小的流應用，這些快照很是輕量，能夠高頻率建立而對性能影響很小。流計

>>阅读原文<<