Flink:實時數據處理(8.容錯機制)

文章目錄 1.⼀致性檢查點(checkpoint) 2.從檢查點恢復狀態 3.Flink 檢查點算法(Chandy-Lamport算法) 3.1 ⼀種簡單的想法(同步的思想) 3.2 Flink 的改進實現(異步的思想) 3.3 檢查點分界線(Checkpoint Barrier,檢查點屏障) 3.4 圖示詳解 4.保存點(save points) 1.⼀致性檢查點(checkpoint) Fli
相關文章
相關標籤/搜索