取消时保留 Flink Checkpoint

Question

我正在使用 Flink 1.15.0，我想在取消作业时保留触发的检查点。

Flink 表示这样设置 ExternalizeCheckpointCleanup 模式

env.getCheckpointConfig().setExternalizedCheckpointCleanup(
    CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);

从 Javadoc 他们说：

The target directory for externalized checkpoints is configured via CheckpointingOptions.CHECKPOINTS_DIRECTORY.

所以我写了这一行：

config.set(CheckpointingOptions.CHECKPOINTS_DIRECTORY, "hdfs:///checkpoints-data");

但是在他们的文档中，他们显示了这个 sn-p：

env.getCheckpointConfig().setCheckpointStorage("hdfs:///checkpoints-data/");

检查点目录和检查点存储有什么区别？

Answer 1

相同。你可以直接在你的应用程序中setCheckpointStorage()，或者 Flink 将使用CheckpointingOptions.CHECKPOINTS_DIRECTORY 创建一个检查点存储。