Flink狀態（State）管理和恢復原理解析

1、狀態（State）     一、介紹             咱們在前面寫的word count的例子（上篇博客中有的）,沒有包含狀態管理。若是一個task在處理過程當中掛掉了，那麼它在內存中的狀態都會丟失，全部的數據都須要從新計算。從容錯和消息處理語義上（at last once,exactly once）,從而Flink引入了state和checkpoint。java          

>>阅读原文<<