Hi Jeff You can restore from retained checkpoint such as[1] `bin/flink run -s :checkpointMetaDataPath [:runArgs]` , you may find the metadata in the `chk-xxx` directory[2]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/checkpoints.html#resuming-from-a-retained-checkpoint [2] https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/checkpoints.html#directory-structure Best, Congxian Jeffrey Martin <jeffrey.martin...@gmail.com> 于2020年9月15日周二 下午1:30写道： > Hi, > > My job on Flink 1.10 uses RocksDB with incremental checkpointing enabled. > The checkpoints are retained on cancellation. > > How do I resume from the retained checkpoint after cancellation (e.g., > when upgrading the job binary)? Docs say to use the checkpoint or savepoint > metadata file, but AFAICT there's no metadata file in HDFS in the various > directories under "$checkpointsDir/snapshots/$jobID", > > Thanks, > > Jeff Martin >
