Flink 狀態與容錯 ( state 和 Fault Tolerance)

Flink 狀態與容錯 狀態性的函數和操做經過處理單個(元素/事件)存儲數據，使任何類型的state構建更復雜的操做。html 例如：java 當應用程序針對特定事件模式進行搜索的時候，state將會存儲到目前爲止的一些列事件。 當每 分鐘/小時/天 聚合事件的時候，state會持有全部等待聚合的數據。 當在一連串的數據流上訓練機器學習模型時，state持有當前版本的模型參數。 當歷史數據須要管理

>>阅读原文<<