@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> |
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.
|
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<Integer> |
MAX_ATTEMPTS_HISTORY_SIZE
The maximum number of prior execution attempts kept in history.
|
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<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.
|
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<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<String> JOB_MANAGER_HEAP_MEMORY
@Deprecated public static final ConfigOption<Integer> JOB_MANAGER_HEAP_MEMORY_MB
JOB_MANAGER_HEAP_MEMORY
public static final ConfigOption<Integer> MAX_ATTEMPTS_HISTORY_SIZE
public static final ConfigOption<String> EXECUTION_FAILOVER_STRATEGY
The option "individual" is intentionally not included for its known limitations. It only works when all tasks are not connected, in which case the "region" failover strategy would also restart failed tasks individually. The new "region" strategy supersedes "individual" strategy and should always work.
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<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–2020 The Apache Software Foundation. All rights reserved.