@PublicEvolving public class ResourceManagerOptions extends Object
Modifier and Type | Field and Description |
---|---|
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<Duration> |
DECLARE_NEEDED_RESOURCE_DELAY |
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
Deprecated.
|
static ConfigOption<Integer> |
MAX_SLOT_NUM |
static ConfigOption<Double> |
MAX_TOTAL_CPU |
static ConfigOption<MemorySize> |
MAX_TOTAL_MEM |
static ConfigOption<Integer> |
REDUNDANT_TASK_MANAGER_NUM
The number of redundant task managers.
|
static ConfigOption<Duration> |
REQUIREMENTS_CHECK_DELAY |
static ConfigOption<Duration> |
RESOURCE_MANAGER_PREVIOUS_WORKER_RECOVERY_TIMEOUT
Timeout for ResourceManager to recover all the previous attempts workers.
|
static ConfigOption<Long> |
SLOT_MANAGER_TASK_MANAGER_TIMEOUT
Deprecated.
Use
TASK_MANAGER_TIMEOUT . |
static ConfigOption<Long> |
STANDALONE_CLUSTER_STARTUP_PERIOD_TIME
Time in milliseconds of the start-up period of a standalone cluster.
|
static ConfigOption<Double> |
START_WORKER_MAX_FAILURE_RATE
The maximum number of start worker failures (Native Kubernetes / Yarn) per minute before
pausing requesting new workers.
|
static ConfigOption<Duration> |
START_WORKER_RETRY_INTERVAL
The time to wait before requesting new workers (Native Kubernetes / Yarn) once the max
failure rate of starting workers (
START_WORKER_MAX_FAILURE_RATE ) is reached. |
static ConfigOption<Duration> |
TASK_MANAGER_REGISTRATION_TIMEOUT
Timeout for TaskManagers to register at the active resource managers.
|
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
@Deprecated public static final ConfigOption<Integer> LOCAL_NUMBER_RESOURCE_MANAGER
public static final ConfigOption<Integer> IPC_PORT
public static final ConfigOption<Integer> MAX_SLOT_NUM
public static final ConfigOption<Double> MAX_TOTAL_CPU
public static final ConfigOption<MemorySize> MAX_TOTAL_MEM
public static final ConfigOption<Integer> REDUNDANT_TASK_MANAGER_NUM
public static final ConfigOption<Double> START_WORKER_MAX_FAILURE_RATE
START_WORKER_RETRY_INTERVAL
).public static final ConfigOption<Duration> START_WORKER_RETRY_INTERVAL
START_WORKER_MAX_FAILURE_RATE
) is reached.public static final ConfigOption<Duration> REQUIREMENTS_CHECK_DELAY
public static final ConfigOption<Duration> DECLARE_NEEDED_RESOURCE_DELAY
public static final ConfigOption<Long> STANDALONE_CLUSTER_STARTUP_PERIOD_TIME
JobManagerOptions.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).public static final ConfigOption<Duration> TASK_MANAGER_REGISTRATION_TIMEOUT
public static final ConfigOption<Duration> RESOURCE_MANAGER_PREVIOUS_WORKER_RECOVERY_TIMEOUT
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.