pyflink.datastream.checkpoint_config.CheckpointConfig.set_alignment_timeout

CheckpointConfig.set_alignment_timeout(alignment_timeout: Duration) → CheckpointConfig

Only relevant if enable_unaligned_checkpoints() is enabled.

If alignment_timeout has value equal to 0, checkpoints will always start unaligned. If alignment_timeout has value greater then 0, checkpoints will start aligned. If during checkpointing, checkpoint start delay exceeds this alignment_timeout, alignment will timeout and checkpoint will start working as unaligned checkpoint.

Parameters

alignment_timeout – The duration until the aligned checkpoint will be converted into an unaligned checkpoint.