取消时保留Flink检查点

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");

但在他们的文档中，他们显示了以下片段：

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

检查点目录和检查点存储之间的区别是什么？

Answer 1

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