pyflink.datastream.checkpoint_config.CheckpointConfig.set_max_concurrent_checkpoints

CheckpointConfig.set_max_concurrent_checkpoints(max_concurrent_checkpoints: int) → CheckpointConfig

Sets the maximum number of checkpoint attempts that may be in progress at the same time. If this value is n, then no checkpoints will be triggered while n checkpoint attempts are currently in flight. For the next checkpoint to be triggered, one checkpoint attempt would need to finish or expire.

Parameters:

max_concurrent_checkpoints – The maximum number of concurrent checkpoint attempts.