我们正在测试flink的本地恢复选项,以实现我们的大键控状态的快速恢复。我们取消了当前正在运行的作业,然后从最后一个检查点重新启动它,发现以前的状态仍保留在文件系统中。我们想问,即使我们已经恢复了状态文件,它是否也不会被删除。我们不希望本地任务的磁盘使用量无限增加。
inkz8wg91#
状态文件不会被删除,因为有一个新的jobid分配给恢复的作业,所以flink将创建一个新目录来存储检查点文件。这对我来说完全有意义。假设flink在恢复后删除了状态文件,如果程序再次失败,你会怎么做?
1条答案
按热度按时间inkz8wg91#
状态文件不会被删除,因为有一个新的jobid分配给恢复的作业,所以flink将创建一个新目录来存储检查点文件。这对我来说完全有意义。
假设flink在恢复后删除了状态文件,如果程序再次失败,你会怎么做?