org.apache.flink.configuration

Class JobManagerOptions

java.lang.Object

org.apache.flink.configuration.JobManagerOptions

@PublicEvolving
public class JobManagerOptions
extends Object

Configuration options for the JobManager.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	ADDRESS The config parameter defining the network address to connect to for communication with the job manager.
static ConfigOption<String>	ARCHIVE_DIR The location where the JobManager stores the archives of completed jobs.
static ConfigOption<String>	EXECUTION_FAILOVER_STRATEGY This option specifies the failover strategy, i.e.
static ConfigOption<String>	JOB_MANAGER_HEAP_MEMORY JVM heap size for the JobManager with memory size.
static ConfigOption<Integer>	JOB_MANAGER_HEAP_MEMORY_MB Deprecated. use JOB_MANAGER_HEAP_MEMORY
static ConfigOption<Long>	JOB_STORE_CACHE_SIZE The job store cache size in bytes which is used to keep completed jobs in memory.
static ConfigOption<Long>	JOB_STORE_EXPIRATION_TIME The time in seconds after which a completed job expires and is purged from the job store.
static ConfigOption<Integer>	MAX_ATTEMPTS_HISTORY_SIZE The maximum number of prior execution attempts kept in history.
static ConfigOption<Integer>	PORT The config parameter defining the network port to connect to for communication with the job manager.
static ConfigOption<Long>	RESOURCE_MANAGER_RECONNECT_INTERVAL This option specifies the interval in order to trigger a resource manager reconnection if the connection to the resource manager has been lost.
static ConfigOption<Long>	SLOT_IDLE_TIMEOUT The timeout in milliseconds for a idle slot in Slot Pool.
static ConfigOption<Long>	SLOT_REQUEST_TIMEOUT The timeout in milliseconds for requesting a slot from Slot Pool.

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

ADDRESS

public static final ConfigOption<String> ADDRESS

The config parameter defining the network address to connect to for communication with the job manager.

This value is only interpreted in setups where a single JobManager with static name or address exists (simple standalone setups, or container setups with dynamic service name resolution). It is not used in many high-availability setups, when a leader-election service (like ZooKeeper) is used to elect and discover the JobManager leader from potentially multiple standby JobManagers.

PORT

public static final ConfigOption<Integer> PORT

The config parameter defining the network port to connect to for communication with the job manager.

Like ADDRESS, this value is only interpreted in setups where a single JobManager with static name/address and port exists (simple standalone setups, or container setups with dynamic service name resolution). This config option is not used in many high-availability setups, when a leader-election service (like ZooKeeper) is used to elect and discover the JobManager leader from potentially multiple standby JobManagers.

JOB_MANAGER_HEAP_MEMORY

public static final ConfigOption<String> JOB_MANAGER_HEAP_MEMORY

JVM heap size for the JobManager with memory size.

JOB_MANAGER_HEAP_MEMORY_MB

@Deprecated
public static final ConfigOption<Integer> JOB_MANAGER_HEAP_MEMORY_MB

Deprecated. use JOB_MANAGER_HEAP_MEMORY

JVM heap size (in megabytes) for the JobManager.

MAX_ATTEMPTS_HISTORY_SIZE

public static final ConfigOption<Integer> MAX_ATTEMPTS_HISTORY_SIZE

The maximum number of prior execution attempts kept in history.

EXECUTION_FAILOVER_STRATEGY

public static final ConfigOption<String> EXECUTION_FAILOVER_STRATEGY

This option specifies the failover strategy, i.e. how the job computation recovers from task failures.

RESOURCE_MANAGER_RECONNECT_INTERVAL

public static final ConfigOption<Long> RESOURCE_MANAGER_RECONNECT_INTERVAL

This option specifies the interval in order to trigger a resource manager reconnection if the connection to the resource manager has been lost.

This option is only intended for internal use.

ARCHIVE_DIR

public static final ConfigOption<String> ARCHIVE_DIR

The location where the JobManager stores the archives of completed jobs.

JOB_STORE_CACHE_SIZE

public static final ConfigOption<Long> JOB_STORE_CACHE_SIZE

The job store cache size in bytes which is used to keep completed jobs in memory.

JOB_STORE_EXPIRATION_TIME

public static final ConfigOption<Long> JOB_STORE_EXPIRATION_TIME

The time in seconds after which a completed job expires and is purged from the job store.

SLOT_REQUEST_TIMEOUT

public static final ConfigOption<Long> SLOT_REQUEST_TIMEOUT

The timeout in milliseconds for requesting a slot from Slot Pool.

SLOT_IDLE_TIMEOUT

public static final ConfigOption<Long> SLOT_IDLE_TIMEOUT

The timeout in milliseconds for a idle slot in Slot Pool.