Job Manager 可以存储检查点多长时间？

Question

Apache Flink 允许在作业管理器内存中存储检查点 (state.backend = jobmanager)。

例如，我的流程创建了 1,000,000 个检查点。所有这些都将存储在 Job Manager 内存中，或者 Job Manager 会定期删除旧检查点？

Answer 1

Flink 只会保留最新完成的检查点。所有较旧的检查点都将被丢弃，因此它们占据的 memory/resources 将被释放。