org.apache.flink.streaming.api.environment

Class ExecutionCheckpointingOptions

java.lang.Object

org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions

@PublicEvolving
public class ExecutionCheckpointingOptions
extends Object

Execution ConfigOption for configuring checkpointing related parameters.

See Also:

CheckpointConfig

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<java.time.Duration>	ALIGNED_CHECKPOINT_TIMEOUT
static ConfigOption<java.time.Duration>	ALIGNMENT_TIMEOUT Deprecated. Use ALIGNED_CHECKPOINT_TIMEOUT instead.
static ConfigOption<Boolean>	APPROXIMATE_LOCAL_RECOVERY Access to this option is officially only supported via CheckpointConfig.enableApproximateLocalRecovery(boolean), but there is no good reason behind this.
static ConfigOption<Long>	CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA
static ConfigOption<java.time.Duration>	CHECKPOINTING_INTERVAL
static ConfigOption<java.time.Duration>	CHECKPOINTING_INTERVAL_DURING_BACKLOG
static ConfigOption<CheckpointingMode>	CHECKPOINTING_MODE
static ConfigOption<java.time.Duration>	CHECKPOINTING_TIMEOUT
static ConfigOption<Boolean>	ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH
static ConfigOption<Boolean>	ENABLE_UNALIGNED
static ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup>	EXTERNALIZED_CHECKPOINT
static ConfigOption<Boolean>	FORCE_CHECKPOINTING Deprecated. This will be removed once iterations properly participate in checkpointing.
static ConfigOption<Boolean>	FORCE_UNALIGNED
static ConfigOption<Integer>	MAX_CONCURRENT_CHECKPOINTS
static ConfigOption<java.time.Duration>	MIN_PAUSE_BETWEEN_CHECKPOINTS
static ConfigOption<Integer>	TOLERABLE_FAILURE_NUMBER
static ConfigOption<Integer>	UNALIGNED_MAX_SUBTASKS_PER_CHANNEL_STATE_FILE

Constructor Summary

Constructors

Constructor and Description
ExecutionCheckpointingOptions()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CHECKPOINTING_MODE

public static final ConfigOption<CheckpointingMode> CHECKPOINTING_MODE

CHECKPOINTING_TIMEOUT

public static final ConfigOption<java.time.Duration> CHECKPOINTING_TIMEOUT

MAX_CONCURRENT_CHECKPOINTS

public static final ConfigOption<Integer> MAX_CONCURRENT_CHECKPOINTS

MIN_PAUSE_BETWEEN_CHECKPOINTS

public static final ConfigOption<java.time.Duration> MIN_PAUSE_BETWEEN_CHECKPOINTS

TOLERABLE_FAILURE_NUMBER

public static final ConfigOption<Integer> TOLERABLE_FAILURE_NUMBER

EXTERNALIZED_CHECKPOINT

public static final ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> EXTERNALIZED_CHECKPOINT

CHECKPOINTING_INTERVAL_DURING_BACKLOG

public static final ConfigOption<java.time.Duration> CHECKPOINTING_INTERVAL_DURING_BACKLOG

CHECKPOINTING_INTERVAL

public static final ConfigOption<java.time.Duration> CHECKPOINTING_INTERVAL

ENABLE_UNALIGNED

public static final ConfigOption<Boolean> ENABLE_UNALIGNED

ALIGNED_CHECKPOINT_TIMEOUT

public static final ConfigOption<java.time.Duration> ALIGNED_CHECKPOINT_TIMEOUT

ALIGNMENT_TIMEOUT

@Deprecated
public static final ConfigOption<java.time.Duration> ALIGNMENT_TIMEOUT

Deprecated. Use ALIGNED_CHECKPOINT_TIMEOUT instead.

FORCE_UNALIGNED

public static final ConfigOption<Boolean> FORCE_UNALIGNED

CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA

public static final ConfigOption<Long> CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA

ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH

public static final ConfigOption<Boolean> ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH

FORCE_CHECKPOINTING

@Internal
 @Deprecated
public static final ConfigOption<Boolean> FORCE_CHECKPOINTING

Deprecated. This will be removed once iterations properly participate in checkpointing.

Access to this option is officially only supported via CheckpointConfig.setForceCheckpointing(boolean), but there is no good reason behind this.

APPROXIMATE_LOCAL_RECOVERY

@Internal
public static final ConfigOption<Boolean> APPROXIMATE_LOCAL_RECOVERY

Access to this option is officially only supported via CheckpointConfig.enableApproximateLocalRecovery(boolean), but there is no good reason behind this.

UNALIGNED_MAX_SUBTASKS_PER_CHANNEL_STATE_FILE

public static final ConfigOption<Integer> UNALIGNED_MAX_SUBTASKS_PER_CHANNEL_STATE_FILE

Constructor Detail

ExecutionCheckpointingOptions

public ExecutionCheckpointingOptions()