Flink通過checkpoint實現狀態恢復

1，我們先看一下最簡單的代碼，消費kafka的數據然後state存儲，通過checkpoint保存到hdfs package application; import appOperator.stateMap; import org.apache.flink.api.common.restartstrategy.RestartStrategies; import org.apache.flink.

>>阅读原文<<