@PublicEvolving public class ResourceManagerOptions extends Object
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
Defines the network port to connect to for communication with the resource manager.
|
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
The number of resource managers start.
|
static ConfigOption<Long> |
SLOT_MANAGER_TASK_MANAGER_TIMEOUT
Deprecated.
Use
TASK_MANAGER_TIMEOUT . |
static ConfigOption<Long> |
SLOT_REQUEST_TIMEOUT
Deprecated.
|
static ConfigOption<Long> |
STANDALONE_CLUSTER_STARTUP_PERIOD_TIME
Time in milliseconds of the start-up period of a standalone cluster.
|
static ConfigOption<Boolean> |
TASK_MANAGER_RELEASE_WHEN_RESULT_CONSUMED
Deprecated.
The default value should be reasonable enough in all cases, this option is to fallback to older behaviour
which will be removed or refactored in future.
|
static ConfigOption<Long> |
TASK_MANAGER_TIMEOUT
The timeout for an idle task manager to be released, in milliseconds.
|
public static final ConfigOption<String> JOB_TIMEOUT
public static final ConfigOption<Integer> LOCAL_NUMBER_RESOURCE_MANAGER
public static final ConfigOption<Integer> IPC_PORT
public static final ConfigOption<Float> CONTAINERIZED_HEAP_CUTOFF_RATIO
public static final ConfigOption<Integer> CONTAINERIZED_HEAP_CUTOFF_MIN
@Deprecated public static final ConfigOption<Long> SLOT_REQUEST_TIMEOUT
JobManagerOptions.SLOT_REQUEST_TIMEOUT
.public static final ConfigOption<Long> STANDALONE_CLUSTER_STARTUP_PERIOD_TIME
SLOT_REQUEST_TIMEOUT
will be used by default.@Deprecated public static final ConfigOption<Long> SLOT_MANAGER_TASK_MANAGER_TIMEOUT
TASK_MANAGER_TIMEOUT
.public static final ConfigOption<Long> TASK_MANAGER_TIMEOUT
@Deprecated public static final ConfigOption<Boolean> TASK_MANAGER_RELEASE_WHEN_RESULT_CONSUMED
Currently, produced result partition is released when it fails or consumer sends close request to confirm successful end of consumption and to close the communication channel.
public static final String CONTAINERIZED_MASTER_ENV_PREFIX
public static final String CONTAINERIZED_TASK_MANAGER_ENV_PREFIX
CONTAINERIZED_MASTER_ENV_PREFIX
, this configuration prefix allows
setting custom environment variables for the workers (TaskManagers).Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.