且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

关于Flink外部化检查点的两个问题

更新时间: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]