Wie lange Job Manager Checkpoints speichern kann?

Question

Apache Flink ermöglichen es, Prüfpunkte im Job-Manager-Speicher zu speichern (state.backend = jobmanager).

Zum Beispiel hat mein Fluss 1.000.000 Checkpoints erstellt. Alle werden im Job Manager gespeichert oder der Job Manager entfernt regelmäßig alte Checkpoints?

Answer 1

Flink behält nur den letzten abgeschlossenen Checkpoint. Alle älteren Checkpoints werden verworfen und somit werden die Speicher/Ressourcen, die sie belegen, freigegeben.