Package org.apache.flink.configuration
Class BatchExecutionOptions
- java.lang.Object
-
- org.apache.flink.configuration.BatchExecutionOptions
-
@PublicEvolving public class BatchExecutionOptions extends Object
Configuration options for the batch job execution.
-
-
Field Summary
Fields Modifier and Type Field Description static ConfigOption<MemorySize>
ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASK
static ConfigOption<Integer>
ADAPTIVE_AUTO_PARALLELISM_DEFAULT_SOURCE_PARALLELISM
static ConfigOption<Boolean>
ADAPTIVE_AUTO_PARALLELISM_ENABLED
static ConfigOption<Integer>
ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM
static ConfigOption<Integer>
ADAPTIVE_AUTO_PARALLELISM_MIN_PARALLELISM
static ConfigOption<Duration>
BLOCK_SLOW_NODE_DURATION
static ConfigOption<Boolean>
JOB_RECOVERY_ENABLED
static ConfigOption<Duration>
JOB_RECOVERY_PREVIOUS_WORKER_RECOVERY_TIMEOUT
static ConfigOption<Duration>
JOB_RECOVERY_SNAPSHOT_MIN_PAUSE
static ConfigOption<Boolean>
SPECULATIVE_ENABLED
static ConfigOption<Integer>
SPECULATIVE_MAX_CONCURRENT_EXECUTIONS
-
-
-
Field Detail
-
ADAPTIVE_AUTO_PARALLELISM_ENABLED
public static final ConfigOption<Boolean> ADAPTIVE_AUTO_PARALLELISM_ENABLED
-
ADAPTIVE_AUTO_PARALLELISM_MIN_PARALLELISM
public static final ConfigOption<Integer> ADAPTIVE_AUTO_PARALLELISM_MIN_PARALLELISM
-
ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM
public static final ConfigOption<Integer> ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM
-
ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASK
public static final ConfigOption<MemorySize> ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASK
-
ADAPTIVE_AUTO_PARALLELISM_DEFAULT_SOURCE_PARALLELISM
public static final ConfigOption<Integer> ADAPTIVE_AUTO_PARALLELISM_DEFAULT_SOURCE_PARALLELISM
-
SPECULATIVE_ENABLED
public static final ConfigOption<Boolean> SPECULATIVE_ENABLED
-
SPECULATIVE_MAX_CONCURRENT_EXECUTIONS
public static final ConfigOption<Integer> SPECULATIVE_MAX_CONCURRENT_EXECUTIONS
-
BLOCK_SLOW_NODE_DURATION
public static final ConfigOption<Duration> BLOCK_SLOW_NODE_DURATION
-
JOB_RECOVERY_ENABLED
public static final ConfigOption<Boolean> JOB_RECOVERY_ENABLED
-
JOB_RECOVERY_PREVIOUS_WORKER_RECOVERY_TIMEOUT
public static final ConfigOption<Duration> JOB_RECOVERY_PREVIOUS_WORKER_RECOVERY_TIMEOUT
-
JOB_RECOVERY_SNAPSHOT_MIN_PAUSE
public static final ConfigOption<Duration> JOB_RECOVERY_SNAPSHOT_MIN_PAUSE
-
-