GitHub user tony810430 opened a pull request:
FLINK-4754 [checkpoints] Make number of retained checkpoints user configurable
I add `CheckpointConfig.setMaxNumberOfCheckpointsToRetain` to expose user the configuration for number of retained checkpoints, and update the constructor of `JobSnapshottingSettings` to pass the value to `CheckpointRecoveryFactory`.
However, I didn't make this value lazily in the checkpoint store implementations.
It is useful to make it lazily if there is a need to reconfigure it during job is running, but I think that should be another issue.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tony810430/flink
Alternatively you can review and apply these changes as the patch at:
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3374
Author: Tony Wei <email@example.com>
FLINK-4754 Make number of retained checkpoints user configurable