【12】Flink 之 狀態(State)管理與CheckPoint容錯恢復

一、狀態(State)管理與恢復 1.一、狀態(State) 咱們前面寫的word count的例子，沒有包含狀態管理。若是一個task在處理過程當中掛掉了，那麼它在內存中的狀態都會丟失，全部的數據都須要從新計算。從容錯和消息處理的語義上(at least once, exactly once)，Flink引入了state和 checkpoint。 首先區分一下兩個概念 state通常指一個具體的

>>阅读原文<<