@PublicEvolving public class ExecutionCheckpointingOptions extends Object
ConfigOption
for configuring checkpointing related parameters.CheckpointConfig
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<Long> |
CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA |
static ConfigOption<java.time.Duration> |
CHECKPOINTING_INTERVAL |
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_UNALIGNED |
static ConfigOption<Integer> |
MAX_CONCURRENT_CHECKPOINTS |
static ConfigOption<java.time.Duration> |
MIN_PAUSE_BETWEEN_CHECKPOINTS |
static ConfigOption<Integer> |
TOLERABLE_FAILURE_NUMBER |
Constructor and Description |
---|
ExecutionCheckpointingOptions() |
public static final ConfigOption<CheckpointingMode> CHECKPOINTING_MODE
public static final ConfigOption<java.time.Duration> CHECKPOINTING_TIMEOUT
public static final ConfigOption<Integer> MAX_CONCURRENT_CHECKPOINTS
public static final ConfigOption<java.time.Duration> MIN_PAUSE_BETWEEN_CHECKPOINTS
public static final ConfigOption<Integer> TOLERABLE_FAILURE_NUMBER
public static final ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> EXTERNALIZED_CHECKPOINT
public static final ConfigOption<java.time.Duration> CHECKPOINTING_INTERVAL
public static final ConfigOption<Boolean> ENABLE_UNALIGNED
public static final ConfigOption<java.time.Duration> ALIGNED_CHECKPOINT_TIMEOUT
@Deprecated public static final ConfigOption<java.time.Duration> ALIGNMENT_TIMEOUT
ALIGNED_CHECKPOINT_TIMEOUT
instead.public static final ConfigOption<Boolean> FORCE_UNALIGNED
public static final ConfigOption<Long> CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA
public static final ConfigOption<Boolean> ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.