Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Connectors
    • Formats
  • PyFlink Common

pyflink.datastream.checkpoint_config.CheckpointConfig.get_min_pause_between_checkpoints#

CheckpointConfig.get_min_pause_between_checkpoints() → int[source]#

Gets 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 get_max_concurrent_checkpoints()).

Returns

The minimal pause before the next checkpoint is triggered.

previous

pyflink.datastream.checkpoint_config.CheckpointConfig.set_checkpoint_timeout

next

pyflink.datastream.checkpoint_config.CheckpointConfig.set_min_pause_between_checkpoints

Show Source

Created using Sphinx 4.5.0.