06-Flink的容錯機制

目錄 一致性檢查點(checkpoint) 從檢查點恢復狀態 Flink檢查點算法 保存點(save points) 一致性檢查點(checkpoint) (1) flink故障恢復機制的核心,就是應用狀態的一致性檢查點 (2) 有狀態流應用的一直檢查點,其實就是所有任務的狀態,在某個時間點的一份拷貝(一份快照);這個時間點,應該是所有任務都恰好處理完一個相同的輸入數據的時候 從檢查點恢復狀態 (
相關文章
相關標籤/搜索