@PublicEvolving public class JobManagerOptions extends Object
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> |
BIND_HOST
The local address of the network interface that the job manager binds to.
|
static ConfigOption<String> |
EXECUTION_FAILOVER_STRATEGY
This option specifies the failover strategy, i.e.
|
static ConfigOption<MemorySize> |
JOB_MANAGER_HEAP_MEMORY
Deprecated.
use
TOTAL_FLINK_MEMORY for standalone setups and TOTAL_PROCESS_MEMORY for containerized setups. |
static ConfigOption<Integer> |
JOB_MANAGER_HEAP_MEMORY_MB
Deprecated.
use
TOTAL_FLINK_MEMORY for standalone setups and TOTAL_PROCESS_MEMORY for containerized setups. |
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> |
JOB_STORE_MAX_CAPACITY
The max number of completed jobs that can be kept in the job store.
|
static ConfigOption<Boolean> |
JVM_DIRECT_MEMORY_LIMIT_ENABLED
Off-heap Memory size for the JobManager.
|
static ConfigOption<MemorySize> |
JVM_HEAP_MEMORY
JVM Heap Memory size for the JobManager.
|
static ConfigOption<MemorySize> |
JVM_METASPACE
JVM Metaspace Size for the JobManager.
|
static ConfigOption<Float> |
JVM_OVERHEAD_FRACTION
Fraction of Total Process Memory to be reserved for JVM Overhead.
|
static ConfigOption<MemorySize> |
JVM_OVERHEAD_MAX
Max JVM Overhead size for the TaskExecutors.
|
static ConfigOption<MemorySize> |
JVM_OVERHEAD_MIN
Min JVM Overhead size for the JobManager.
|
static ConfigOption<Integer> |
MAX_ATTEMPTS_HISTORY_SIZE
The maximum number of prior execution attempts kept in history.
|
static MemorySize |
MIN_JVM_HEAP_SIZE |
static ConfigOption<MemorySize> |
OFF_HEAP_MEMORY
Off-heap Memory size for the JobManager.
|
static ConfigOption<Boolean> |
PARTITION_RELEASE_DURING_JOB_EXECUTION
Config parameter controlling whether partitions should already be released during the job
execution.
|
static ConfigOption<Integer> |
PORT
The config parameter defining the network port to connect to for communication with the job
manager.
|
static ConfigOption<Boolean> |
RETRIEVE_TASK_MANAGER_HOSTNAME
Flag indicating whether JobManager would retrieve canonical host name of TaskManager during
registration.
|
static ConfigOption<Integer> |
RPC_BIND_PORT
The local port that the job manager binds to.
|
static ConfigOption<String> |
SCHEDULER
Config parameter determining the scheduler implementation.
|
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.
|
static ConfigOption<MemorySize> |
TOTAL_FLINK_MEMORY
Total Flink Memory size for the JobManager.
|
static ConfigOption<MemorySize> |
TOTAL_PROCESS_MEMORY
Total Process Memory size for the JobManager.
|
public static final MemorySize MIN_JVM_HEAP_SIZE
public static final ConfigOption<String> ADDRESS
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.
public static final ConfigOption<String> BIND_HOST
public static final ConfigOption<Integer> PORT
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.
public static final ConfigOption<Integer> RPC_BIND_PORT
@Deprecated public static final ConfigOption<MemorySize> JOB_MANAGER_HEAP_MEMORY
TOTAL_FLINK_MEMORY
for standalone setups and TOTAL_PROCESS_MEMORY
for containerized setups.@Deprecated public static final ConfigOption<Integer> JOB_MANAGER_HEAP_MEMORY_MB
TOTAL_FLINK_MEMORY
for standalone setups and TOTAL_PROCESS_MEMORY
for containerized setups.public static final ConfigOption<MemorySize> TOTAL_PROCESS_MEMORY
public static final ConfigOption<MemorySize> TOTAL_FLINK_MEMORY
public static final ConfigOption<MemorySize> JVM_HEAP_MEMORY
public static final ConfigOption<MemorySize> OFF_HEAP_MEMORY
public static final ConfigOption<Boolean> JVM_DIRECT_MEMORY_LIMIT_ENABLED
public static final ConfigOption<MemorySize> JVM_METASPACE
public static final ConfigOption<MemorySize> JVM_OVERHEAD_MIN
public static final ConfigOption<MemorySize> JVM_OVERHEAD_MAX
public static final ConfigOption<Float> JVM_OVERHEAD_FRACTION
public static final ConfigOption<Integer> MAX_ATTEMPTS_HISTORY_SIZE
public static final ConfigOption<String> EXECUTION_FAILOVER_STRATEGY
public static final ConfigOption<String> ARCHIVE_DIR
public static final ConfigOption<Long> JOB_STORE_CACHE_SIZE
public static final ConfigOption<Long> JOB_STORE_EXPIRATION_TIME
public static final ConfigOption<Integer> JOB_STORE_MAX_CAPACITY
public static final ConfigOption<Boolean> RETRIEVE_TASK_MANAGER_HOSTNAME
public static final ConfigOption<Long> SLOT_REQUEST_TIMEOUT
public static final ConfigOption<Long> SLOT_IDLE_TIMEOUT
public static final ConfigOption<String> SCHEDULER
public static final ConfigOption<Boolean> PARTITION_RELEASE_DURING_JOB_EXECUTION
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.