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 >
