CheckpointingOptions.@PublicEvolving @Deprecated public class ExecutionCheckpointingOptions extends Object
ConfigOption for configuring checkpointing related parameters.CheckpointConfig| 限定符和类型 | 字段和说明 |
|---|---|
static org.apache.flink.configuration.ConfigOption<Duration> |
ALIGNED_CHECKPOINT_TIMEOUT
已过时。
|
static org.apache.flink.configuration.ConfigOption<Duration> |
ALIGNMENT_TIMEOUT
已过时。
Use
ALIGNED_CHECKPOINT_TIMEOUT instead. |
static org.apache.flink.configuration.ConfigOption<Boolean> |
APPROXIMATE_LOCAL_RECOVERY
已过时。
Use
StateRecoveryOptions#APPROXIMATE_LOCAL_RECOVERY instead. |
static org.apache.flink.configuration.ConfigOption<Long> |
CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA
已过时。
Use
StateRecoveryOptions#CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA instead. |
static org.apache.flink.configuration.ConfigOption<org.apache.flink.core.execution.CheckpointingMode> |
CHECKPOINTING_CONSISTENCY_MODE
已过时。
|
static org.apache.flink.configuration.ConfigOption<Duration> |
CHECKPOINTING_INTERVAL
已过时。
|
static org.apache.flink.configuration.ConfigOption<Duration> |
CHECKPOINTING_INTERVAL_DURING_BACKLOG
已过时。
|
static org.apache.flink.configuration.ConfigOption<CheckpointingMode> |
CHECKPOINTING_MODE
已过时。
|
static org.apache.flink.configuration.ConfigOption<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<org.apache.flink.configuration.ExternalizedCheckpointRetention> |
EXTERNALIZED_CHECKPOINT_RETENTION
已过时。
|
static org.apache.flink.configuration.ConfigOption<Boolean> |
FORCE_CHECKPOINTING
已过时。
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<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
已过时。
|
| 构造器和说明 |
|---|
ExecutionCheckpointingOptions()
已过时。
|
@Deprecated public static final org.apache.flink.configuration.ConfigOption<CheckpointingMode> CHECKPOINTING_MODE
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.core.execution.CheckpointingMode> CHECKPOINTING_CONSISTENCY_MODE
public static final org.apache.flink.configuration.ConfigOption<Duration> CHECKPOINTING_TIMEOUT
public static final org.apache.flink.configuration.ConfigOption<Integer> MAX_CONCURRENT_CHECKPOINTS
public static final org.apache.flink.configuration.ConfigOption<Duration> MIN_PAUSE_BETWEEN_CHECKPOINTS
public static final org.apache.flink.configuration.ConfigOption<Integer> TOLERABLE_FAILURE_NUMBER
@Deprecated public static final org.apache.flink.configuration.ConfigOption<CheckpointConfig.ExternalizedCheckpointCleanup> EXTERNALIZED_CHECKPOINT
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.ExternalizedCheckpointRetention> EXTERNALIZED_CHECKPOINT_RETENTION
public static final org.apache.flink.configuration.ConfigOption<Duration> CHECKPOINTING_INTERVAL_DURING_BACKLOG
public static final org.apache.flink.configuration.ConfigOption<Duration> CHECKPOINTING_INTERVAL
public static final org.apache.flink.configuration.ConfigOption<Boolean> ENABLE_UNALIGNED
public static final org.apache.flink.configuration.ConfigOption<Duration> ALIGNED_CHECKPOINT_TIMEOUT
@Deprecated public static final org.apache.flink.configuration.ConfigOption<Duration> ALIGNMENT_TIMEOUT
ALIGNED_CHECKPOINT_TIMEOUT instead.public static final org.apache.flink.configuration.ConfigOption<Boolean> FORCE_UNALIGNED
@Deprecated public static final org.apache.flink.configuration.ConfigOption<Long> CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA
StateRecoveryOptions#CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA instead.public static final org.apache.flink.configuration.ConfigOption<Boolean> ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH
@Internal @Deprecated public static final org.apache.flink.configuration.ConfigOption<Boolean> FORCE_CHECKPOINTING
CheckpointConfig.setForceCheckpointing(boolean), but there is no good reason behind this.@Internal @Deprecated public static final org.apache.flink.configuration.ConfigOption<Boolean> APPROXIMATE_LOCAL_RECOVERY
StateRecoveryOptions#APPROXIMATE_LOCAL_RECOVERY instead.CheckpointConfig.enableApproximateLocalRecovery(boolean), but there is no good reason behind
this.public static final org.apache.flink.configuration.ConfigOption<Integer> UNALIGNED_MAX_SUBTASKS_PER_CHANNEL_STATE_FILE
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.