Flink 學習(一):容錯機制

Introduce Apache Flink 提供了可以恢復數據流應用到一致狀態的容錯機制。確保在發生故障時,程序恢復時,數據流的每一條記錄只會被處理一次(exactly-once),當然也可以降級爲至少處理一次(at-least-once)。 容錯機制通過持續創建分佈式數據流的快照來實現。對於狀態佔用空間小的流應用,這些快照非常輕量,可以高頻率創建而對性能影響很小。流計算應用的狀態保存在一個可配
相關文章
相關標籤/搜索