Flink:是否可以为检查点提供或分配时间戳



Flink:是否可以为检查点文件夹提供或分配时间戳,就像将最后一个检查点的时间戳附加到以作业id命名的文件夹中一样?是否可以为每个作业的外部检查点提供自定义名称?如果是,如何?

看起来你只能设置根目录路径,然后检查点数据如下所示。

/user-defined-checkpoint-dir
/{job-id}
|
+ --shared/
+ --taskowned/
+ --chk-1/
+ --chk-2/
+ --chk-3/
...

最新更新