Hey Zach and Konstantin, Great questions and answers. We can try to make this more explicit in the docs.
On Tue, Apr 5, 2016 at 8:54 PM, Konstantin Knauf <konstantin.kn...@tngtech.com> wrote: > To my knowledge flink takes care of deleting old checkpoints (I think it > says so in the documentation about savepoints.). In my experience > though, if a job is cancelled or crashes, the checkpoint files are > usually not cleaned up. So some housekeeping might be necessary. Regarding cleanup: currently only the latest successful checkpoint is retained. On graceful shutdown, all checkpoints should be cleaned up as far as I know. Savepoints always have to be cleaned up manually. On crashes, the checkpoint state has to be cleaned up manually (if the JVM shut down hooks did not run). @Konstantin: did you have lingering state without crashes? – Ufuk
