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<java.time.Duration>	BLOCK_SLOW_NODE_DURATION
static ConfigOption<Boolean>	SPECULATIVE_ENABLED
static ConfigOption<Integer>	SPECULATIVE_MAX_CONCURRENT_EXECUTIONS

Method Summary

Methods inherited from class java.lang.Object

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

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<java.time.Duration> BLOCK_SLOW_NODE_DURATION