作业管理器可以存储检查点多长时间

Question

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

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

Answer 1

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