pyflink.datastream.checkpoint_config.CheckpointConfig.enable_unaligned_checkpoints

CheckpointConfig.enable_unaligned_checkpoints(enabled: bool = True) → pyflink.datastream.checkpoint_config.CheckpointConfig

Enables unaligned checkpoints, which greatly reduce checkpointing times under backpressure.

Unaligned checkpoints contain data stored in buffers as part of the checkpoint state, which allows checkpoint barriers to overtake these buffers. Thus, the checkpoint duration becomes independent of the current throughput as checkpoint barriers are effectively not embedded into the stream of data anymore.

Unaligned checkpoints can only be enabled if get_checkpointing_mode() is CheckpointingMode.EXACTLY_ONCE.

Parameters

enabled – True if a checkpoints should be taken in unaligned mode.