Flink 1.5版本的「Task本地恢復」實現摘要

overview 解讀Flink 1.5版本的「task本地恢復」feature的實現。java 隨着時間的推移，Flink有些模塊的代碼複雜度已經很高了（比較典型的就是狀態&容錯這塊）。由於考慮到兼容歷史實現的問題，類在快速增加。web 實現 關於本地恢復的配置，封裝在名爲LocalRecoveryConfig的類中，該類可提供本地恢復模式的查詢（也即LocalRecoveryMode枚舉）以及

>>阅读原文<<