pyflink.datastream.checkpoint_config.CheckpointConfig.set_alignment_timeout#

CheckpointConfig.set_alignment_timeout(alignment_timeout: pyflink.common.time.Duration) → pyflink.datastream.checkpoint_config.CheckpointConfig[source]#

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.