Thanks for providing that information!
On Fri, Dec 1, 2023 at 12:58 AM Zakelly Lan <zakelly....@gmail.com> wrote: > Hi, Rodrigo > > It appears that the configurations you mentioned in your first question are > related to the flink kubernetes operator. Are you using the flink > kubernetes operator? > > In regards to the cleaning behavior when users restore a job from a > savepoint or retained checkpoint, you can find detailed information in: > > https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/#execution-savepoint-restore-mode > (See "execution.savepoint-restore-mode"). Hope this helps. > > > Best, > Zakelly > > On Fri, Dec 1, 2023 at 3:34 AM Rodrigo Meneses <rmene...@gmail.com> wrote: > > > Hi Flink Community, > > > > I'm searching for docs about how the cleaning of checkpoints and > savepoints > > actually work. > > > > I'm interested particularly in the cases when the user has `NATIVE` > format > > (incremental savepoint). Somehow, when using NATIVE format, the number of > > savepoints kept are not matching the savepoint parameters like : > > ``` > > ["kubernetes.operator.savepoint.history.max.age"] = "7d" > > ["kubernetes.operator.savepoint.history.max.count"] = "14" > > ``` > > > > Also, I would like to understand better when the checkpoints are cleaned. > > According to > > > > > https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/checkpoints/ > > the checkpoints are cleaned when a program is cancelled. What happens if > a > > user suspends and then restores the job? Or when a user upgrades the job? > > Are the checkpoints also cleaned in this situation? > > > > Thanks so much for you time > > -Rodrigo > > >
