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.set_min_pause_between_checkpoints#

CheckpointConfig.set_min_pause_between_checkpoints(min_pause_between_checkpoints: int) → CheckpointConfig[source]#

Sets 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 set_max_concurrent_checkpoints()).

If the maximum number of concurrent checkpoints is set to one, this setting makes effectively sure that a minimum amount of time passes where no checkpoint is in progress at all.

Parameters

min_pause_between_checkpoints – The minimal pause before the next checkpoint is triggered.

previous

pyflink.datastream.checkpoint_config.CheckpointConfig.get_min_pause_between_checkpoints

next

pyflink.datastream.checkpoint_config.CheckpointConfig.get_max_concurrent_checkpoints

On this page
  • CheckpointConfig.set_min_pause_between_checkpoints()
Show Source

Created using Sphinx 5.3.0.