org.apache.flink.configuration

Class ExecutionOptions

java.lang.Object

org.apache.flink.configuration.ExecutionOptions

@PublicEvolving
public class ExecutionOptions
extends Object

ConfigOptions specific for a single execution of a user program.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Integer>	ASYNC_INFLIGHT_RECORDS_LIMIT The max limit of in-flight records number in async state execution, 'in-flight' refers to the records that have entered the operator but have not yet been processed and emitted to the downstream.
static ConfigOption<Integer>	ASYNC_STATE_BUFFER_SIZE The size of buffer under async state execution.
static ConfigOption<Long>	ASYNC_STATE_BUFFER_TIMEOUT The timeout of buffer triggering in milliseconds.
static ConfigOption<BatchShuffleMode>	BATCH_SHUFFLE_MODE
static ConfigOption<Duration>	BUFFER_TIMEOUT
static ConfigOption<Boolean>	BUFFER_TIMEOUT_ENABLED
static long	DISABLED_NETWORK_BUFFER_TIMEOUT A special marker value for disabling buffer timeout.
static long	FLUSH_AFTER_EVERY_RECORD A special marker value for flushing network buffers after each record.
static ConfigOption<RuntimeExecutionMode>	RUNTIME_MODE
static ConfigOption<Boolean>	SNAPSHOT_COMPRESSION Should be moved to ExecutionCheckpointingOptions along with ExecutionConfig#useSnapshotCompression, which should be put into CheckpointConfig.
static ConfigOption<Boolean>	SORT_INPUTS
static ConfigOption<MemorySize>	SORT_KEYED_PARTITION_MEMORY
static ConfigOption<MemorySize>	SORT_PARTITION_MEMORY
static ConfigOption<MemorySize>	SORTED_INPUTS_MEMORY
static ConfigOption<Boolean>	USE_BATCH_STATE_BACKEND

Constructor Summary

Constructors

Constructor and Description
ExecutionOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

DISABLED_NETWORK_BUFFER_TIMEOUT

public static final long DISABLED_NETWORK_BUFFER_TIMEOUT

A special marker value for disabling buffer timeout.

See Also:

Constant Field Values

FLUSH_AFTER_EVERY_RECORD

public static final long FLUSH_AFTER_EVERY_RECORD

A special marker value for flushing network buffers after each record.

See Also:

Constant Field Values

RUNTIME_MODE

public static final ConfigOption<RuntimeExecutionMode> RUNTIME_MODE

BATCH_SHUFFLE_MODE

public static final ConfigOption<BatchShuffleMode> BATCH_SHUFFLE_MODE

SNAPSHOT_COMPRESSION

public static final ConfigOption<Boolean> SNAPSHOT_COMPRESSION

Should be moved to ExecutionCheckpointingOptions along with ExecutionConfig#useSnapshotCompression, which should be put into CheckpointConfig.

BUFFER_TIMEOUT_ENABLED

public static final ConfigOption<Boolean> BUFFER_TIMEOUT_ENABLED

BUFFER_TIMEOUT

public static final ConfigOption<Duration> BUFFER_TIMEOUT

SORT_PARTITION_MEMORY

public static final ConfigOption<MemorySize> SORT_PARTITION_MEMORY

SORT_KEYED_PARTITION_MEMORY

public static final ConfigOption<MemorySize> SORT_KEYED_PARTITION_MEMORY

SORT_INPUTS

public static final ConfigOption<Boolean> SORT_INPUTS

SORTED_INPUTS_MEMORY

public static final ConfigOption<MemorySize> SORTED_INPUTS_MEMORY

USE_BATCH_STATE_BACKEND

public static final ConfigOption<Boolean> USE_BATCH_STATE_BACKEND

ASYNC_INFLIGHT_RECORDS_LIMIT

@Experimental
public static final ConfigOption<Integer> ASYNC_INFLIGHT_RECORDS_LIMIT

The max limit of in-flight records number in async state execution, 'in-flight' refers to the records that have entered the operator but have not yet been processed and emitted to the downstream. If the in-flight records number exceeds the limit, the newly records entering will be blocked until the in-flight records number drops below the limit.

ASYNC_STATE_BUFFER_SIZE

@Experimental
public static final ConfigOption<Integer> ASYNC_STATE_BUFFER_SIZE

The size of buffer under async state execution. Async state execution provides a buffer mechanism to reduce state access. When the number of state requests in the buffer exceeds the batch size, a batched state execution would be triggered. Larger batch sizes will bring higher end-to-end latency, this option works with ASYNC_STATE_BUFFER_TIMEOUT to control the frequency of triggering.

ASYNC_STATE_BUFFER_TIMEOUT

@Experimental
public static final ConfigOption<Long> ASYNC_STATE_BUFFER_TIMEOUT

The timeout of buffer triggering in milliseconds. If the buffer has not reached the ASYNC_STATE_BUFFER_SIZE within 'buffer-timeout' milliseconds, a trigger will perform actively.

Constructor Detail

ExecutionOptions

public ExecutionOptions()