Flink的容錯機制第二篇 異步柵欄快照機制

上一篇講到Flink是基於有狀態的運算,而避免了傳統流計算缺少程序狀態支持的數據存儲,訪問,動態擴容,數據庫回滾一致性等問題。這一篇主要講Flink如何通過狀態管理而做到流計算中的消息傳輸保障。 一,一致性與全局狀態 在分佈式系統中,運行着多個相互關聯的服務節點。 一致性是指分佈式系統中的多個服務節點,給定一系列的操作,在約定協議的保障下,使它們對外界呈現的狀態是一致的。換句話說,也就是保證集羣中
相關文章
相關標籤/搜索