更新时间:2023-01-10 20:15:13
您可以控制取消作业时是否删除外部检查点.如果要保留它们,可以执行以下操作:
You can control whether externalized checkpoints are deleted when the job is cancelled. If you want to retain them, you can do this:
CheckpointConfig config = env.getCheckpointConfig();
config.enableExternalizedCheckpoints(ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
For more info, see the docs.
致 ="nofollow noreferrer">从外部检查点恢复(与从保存点恢复相同):
To resume from an externalized checkpoint one does this (the same as resuming from a savepoint):
$ bin/flink run -s :checkpointMetaDataPath [:runArgs]