Flink源碼解析之State的實現

State的實現 Flink經過異步的checkpoint機制來實現流式處理過程當中的容錯，簡單來說就是定時地將本地的狀態序列化到一個持久存儲中，當出現錯誤是經過恢復檢查點的狀態來實現容錯的，對於機制的詳細介紹能夠參見這個連接，本章主要講述flink源碼中state的實現。html StateBackendapache flink將咱們代碼中的操做轉化爲一個個的task放在taskmanager中

>>阅读原文<<