Flink 狀態管理與容錯機制

參考 Apache Flink 零基礎入門系列文章。 狀態管理的基本概念 什麼是狀態 在批處理過程中，數據是劃分爲塊分片去完成的，然後每一個Task去處理一個分片。當分片執行完成後，把輸出聚合起來就是最終的結果。在這個過程當中，對於state的需求還是比較小的。 在流計算過程中，對State有非常高的要求，因爲在流系統中輸入是一個無限制的流，會持續運行從不間斷。在這個過程當中，就需要將狀態數據很好

>>阅读原文<<