org.apache.flink.configuration

Class ResourceManagerOptions

java.lang.Object

org.apache.flink.configuration.ResourceManagerOptions

@PublicEvolving
public class ResourceManagerOptions
extends Object

The set of configuration options relating to the ResourceManager.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<Integer>	CONTAINERIZED_HEAP_CUTOFF_MIN Minimum amount of heap memory to remove in containers, as a safety margin.
static ConfigOption<Float>	CONTAINERIZED_HEAP_CUTOFF_RATIO Percentage of heap space to remove from containers (YARN / Mesos), to compensate for other JVM memory usage.
static String	CONTAINERIZED_MASTER_ENV_PREFIX Prefix for passing custom environment variables to Flink's master process.
static String	CONTAINERIZED_TASK_MANAGER_ENV_PREFIX Similar to the CONTAINERIZED_MASTER_ENV_PREFIX, this configuration prefix allows setting custom environment variables for the workers (TaskManagers).
static ConfigOption<Integer>	IPC_PORT
static ConfigOption<String>	JOB_TIMEOUT Timeout for jobs which don't have a job manager as leader assigned.
static ConfigOption<Integer>	LOCAL_NUMBER_RESOURCE_MANAGER
static ConfigOption<Long>	SLOT_REQUEST_TIMEOUT The timeout for a slot request to be discarded, in milliseconds.
static ConfigOption<Long>	TASK_MANAGER_TIMEOUT The timeout for an idle task manager to be released, in milliseconds.

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

JOB_TIMEOUT

public static final ConfigOption<String> JOB_TIMEOUT

Timeout for jobs which don't have a job manager as leader assigned.

LOCAL_NUMBER_RESOURCE_MANAGER

public static final ConfigOption<Integer> LOCAL_NUMBER_RESOURCE_MANAGER

IPC_PORT

public static final ConfigOption<Integer> IPC_PORT

CONTAINERIZED_HEAP_CUTOFF_RATIO

public static final ConfigOption<Float> CONTAINERIZED_HEAP_CUTOFF_RATIO

Percentage of heap space to remove from containers (YARN / Mesos), to compensate for other JVM memory usage.

CONTAINERIZED_HEAP_CUTOFF_MIN

public static final ConfigOption<Integer> CONTAINERIZED_HEAP_CUTOFF_MIN

Minimum amount of heap memory to remove in containers, as a safety margin.

SLOT_REQUEST_TIMEOUT

public static final ConfigOption<Long> SLOT_REQUEST_TIMEOUT

The timeout for a slot request to be discarded, in milliseconds.

TASK_MANAGER_TIMEOUT

public static final ConfigOption<Long> TASK_MANAGER_TIMEOUT

The timeout for an idle task manager to be released, in milliseconds.

CONTAINERIZED_MASTER_ENV_PREFIX

public static final String CONTAINERIZED_MASTER_ENV_PREFIX

Prefix for passing custom environment variables to Flink's master process. For example for passing LD_LIBRARY_PATH as an env variable to the AppMaster, set: containerized.master.env.LD_LIBRARY_PATH: "/usr/lib/native" in the flink-conf.yaml.

See Also:

Constant Field Values

CONTAINERIZED_TASK_MANAGER_ENV_PREFIX

public static final String CONTAINERIZED_TASK_MANAGER_ENV_PREFIX

Similar to the CONTAINERIZED_MASTER_ENV_PREFIX, this configuration prefix allows setting custom environment variables for the workers (TaskManagers).

See Also:

Constant Field Values