Skip to main content
Ctrl+K
PyFlink 1.20+vvr.11.7.dev0 documentation - Home PyFlink 1.20+vvr.11.7.dev0 documentation - Home
  • API Reference
  • Examples
  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
    • StreamExecutionEnvironment
    • DataStream
    • Functions
    • State
    • Timer
    • Window
    • Checkpoint
    • Side Outputs
    • Asynchronous I/O
    • Connectors
    • Formats
  • PyFlink DataFrame
  • PyFlink Common
  • API Reference
  • PyFlink DataStream
  • Checkpoint
  • pyflink.datastream.checkpoint_config.CheckpointConfig.get_min_pause_between_checkpoints

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

On this page
  • CheckpointConfig.get_min_pause_between_checkpoints()

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.