Thanks for the details Konstantin and Ufuk!
On Tue, Apr 5, 2016 at 2:39 PM Konstantin Knauf < konstantin.kn...@tngtech.com> wrote: > 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 >
