Hi Ufuk, I thought so, but I am not sure when and where ;) I will let you know, if I come across it again.
Cheers, Konstantin On 05.04.2016 21:10, Ufuk Celebi wrote: > 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 > -- Konstantin Knauf * konstantin.kn...@tngtech.com * +49-174-3413182 TNG Technology Consulting GmbH, Betastr. 13a, 85774 Unterföhring Geschäftsführer: Henrik Klagges, Christoph Stock, Dr. Robert Dahlke Sitz: Unterföhring * Amtsgericht München * HRB 135082
