pyflink.datastream.checkpoint_config.CheckpointConfig.get_alignment_timeout#

CheckpointConfig.get_alignment_timeout() → Duration[source]#

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