Как долго менеджер заданий может хранить контрольно-пропускные пункты?

Question

Apache Flink позволяет хранить контрольные точки в памяти менеджера заданий (state.backend = jobmanager).

Например, мой поток создал 1,000,000 контрольных точек. Все они будут сохранены в памяти диспетчера заданий или Менеджер заданий будет периодически удалять старые контрольные точки?

Answer 1

Флинк будет хранить только последнюю завершенную контрольную точку. Все старые контрольные точки будут отброшены, и, следовательно, память/ресурсы, которые они занимают, будут освобождены.