pyflink.datastream.checkpoint_config.CheckpointConfig.set_min_pause_between_checkpoints

CheckpointConfig.set_min_pause_between_checkpoints(min_pause_between_checkpoints: int) → pyflink.datastream.checkpoint_config.CheckpointConfig

Sets the minimal pause between checkpointing attempts. This setting defines how soon the checkpoint coordinator may trigger another checkpoint after it becomes possible to trigger another checkpoint with respect to the maximum number of concurrent checkpoints (see set_max_concurrent_checkpoints()).

If the maximum number of concurrent checkpoints is set to one, this setting makes effectively sure that a minimum amount of time passes where no checkpoint is in progress at all.

Parameters

min_pause_between_checkpoints – The minimal pause before the next checkpoint is triggered.