pyflink.datastream.checkpoint_config.CheckpointConfig.get_max_concurrent_checkpoints

CheckpointConfig.get_max_concurrent_checkpoints() → int

Gets 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.

Returns

The maximum number of concurrent checkpoint attempts.