pyflink.datastream.checkpoint_config.CheckpointConfig.set_checkpoint_interval#
- CheckpointConfig.set_checkpoint_interval(checkpoint_interval: int) pyflink.datastream.checkpoint_config.CheckpointConfig [source]#
Sets the interval in which checkpoints are periodically scheduled.
This setting defines the base interval. Checkpoint triggering may be delayed by the settings
set_max_concurrent_checkpoints()
andset_min_pause_between_checkpoints()
.- Parameters
checkpoint_interval – The checkpoint interval, in milliseconds.