清除flink本地恢复状态文件

qmb5sa22  于 2021-04-21  发布在  Flink
关注(0)|答案(1)|浏览(392)

我们正在测试flink的本地恢复选项,以实现我们的大键控状态的快速恢复。我们取消了当前正在运行的作业,然后从最后一个检查点重新启动它,发现以前的状态仍保留在文件系统中。我们想问,即使我们已经恢复了状态文件,它是否也不会被删除。我们不希望本地任务的磁盘使用量无限增加。

inkz8wg9

inkz8wg91#

状态文件不会被删除,因为有一个新的jobid分配给恢复的作业,所以flink将创建一个新目录来存储检查点文件。这对我来说完全有意义。
假设flink在恢复后删除了状态文件,如果程序再次失败,你会怎么做?

相关问题