pyflink.datastream.checkpoint_config.CheckpointConfig.get_alignment_timeout

CheckpointConfig.get_alignment_timeout() → pyflink.common.time.Duration

Returns the alignment timeout, as configured via set_alignment_timeout() or org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions#ALIGNMENT_TIMEOUT.

Returns

the alignment timeout.