pyflink.datastream.checkpoint_config.CheckpointConfig.get_checkpoint_interval

CheckpointConfig.get_checkpoint_interval() → int

Gets the interval in which checkpoints are periodically scheduled.

This setting defines the base interval. Checkpoint triggering may be delayed by the settings get_max_concurrent_checkpoints() and get_min_pause_between_checkpoints().

Returns:

The checkpoint interval, in milliseconds.