Package 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	Description
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	ALIGNED_CHECKPOINT_TIMEOUT
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	ALIGNMENT_TIMEOUT	Deprecated. Use ALIGNED_CHECKPOINT_TIMEOUT instead.
static org.apache.flink.configuration.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 org.apache.flink.configuration.ConfigOption<Long>	CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	CHECKPOINTING_INTERVAL
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	CHECKPOINTING_INTERVAL_DURING_BACKLOG
static org.apache.flink.configuration.ConfigOption<CheckpointingMode>	CHECKPOINTING_MODE
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	CHECKPOINTING_TIMEOUT
static org.apache.flink.configuration.ConfigOption<Boolean>	ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH
static org.apache.flink.configuration.ConfigOption<Boolean>	ENABLE_UNALIGNED
static org.apache.flink.configuration.ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup>	EXTERNALIZED_CHECKPOINT
static org.apache.flink.configuration.ConfigOption<Boolean>	FORCE_CHECKPOINTING	Deprecated. This will be removed once iterations properly participate in checkpointing.
static org.apache.flink.configuration.ConfigOption<Boolean>	FORCE_UNALIGNED
static org.apache.flink.configuration.ConfigOption<Integer>	MAX_CONCURRENT_CHECKPOINTS
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	MIN_PAUSE_BETWEEN_CHECKPOINTS
static org.apache.flink.configuration.ConfigOption<Integer>	TOLERABLE_FAILURE_NUMBER
static org.apache.flink.configuration.ConfigOption<Integer>	UNALIGNED_MAX_SUBTASKS_PER_CHANNEL_STATE_FILE

Constructor Summary

Constructors

Constructor	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 org.apache.flink.configuration.ConfigOption<CheckpointingMode> CHECKPOINTING_MODE

CHECKPOINTING_TIMEOUT

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> CHECKPOINTING_TIMEOUT

MAX_CONCURRENT_CHECKPOINTS

public static final org.apache.flink.configuration.ConfigOption<Integer> MAX_CONCURRENT_CHECKPOINTS

MIN_PAUSE_BETWEEN_CHECKPOINTS

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> MIN_PAUSE_BETWEEN_CHECKPOINTS

TOLERABLE_FAILURE_NUMBER

public static final org.apache.flink.configuration.ConfigOption<Integer> TOLERABLE_FAILURE_NUMBER

EXTERNALIZED_CHECKPOINT

public static final org.apache.flink.configuration.ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> EXTERNALIZED_CHECKPOINT

CHECKPOINTING_INTERVAL_DURING_BACKLOG

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> CHECKPOINTING_INTERVAL_DURING_BACKLOG

CHECKPOINTING_INTERVAL

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> CHECKPOINTING_INTERVAL

ENABLE_UNALIGNED

public static final org.apache.flink.configuration.ConfigOption<Boolean> ENABLE_UNALIGNED

ALIGNED_CHECKPOINT_TIMEOUT

public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> ALIGNED_CHECKPOINT_TIMEOUT

ALIGNMENT_TIMEOUT

@Deprecated
public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> ALIGNMENT_TIMEOUT

Deprecated.

Use ALIGNED_CHECKPOINT_TIMEOUT instead.

FORCE_UNALIGNED

public static final org.apache.flink.configuration.ConfigOption<Boolean> FORCE_UNALIGNED

CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA

public static final org.apache.flink.configuration.ConfigOption<Long> CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA

ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH

public static final org.apache.flink.configuration.ConfigOption<Boolean> ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH

FORCE_CHECKPOINTING

@Internal
@Deprecated
public static final org.apache.flink.configuration.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 org.apache.flink.configuration.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 org.apache.flink.configuration.ConfigOption<Integer> UNALIGNED_MAX_SUBTASKS_PER_CHANNEL_STATE_FILE

Constructor Detail

ExecutionCheckpointingOptions

public ExecutionCheckpointingOptions()