Flink檢查點(Checkpoints)/保存點(Savepoints)恢復

環境 Flink:1.6.1 Scala:2.11.12 jdk1.8 Hello World package flink import org.apache.flink.core.fs.Path import org.apache.flink.runtime.state.StateBackend import org.apache.flink.runtime.state.filesystem.
相關文章
相關標籤/搜索