@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
The maximum number of prior execution attempts kept in history.
|
static ConfigOption<Integer> |
JOB_MANAGER_HEAP_MEMORY
JVM heap size (in megabytes) for the JobManager
|
static ConfigOption<Integer> |
MAX_ATTEMPTS_HISTORY_SIZE
The maximum number of prior execution attempts kept in history.
|
static ConfigOption<Integer> |
PORT
The config parameter defining the network port to connect to
for communication with the job manager.
|
static ConfigOption<Long> |
RESOURCE_MANAGER_RECONNECT_INTERVAL
This option specifies the interval in order to trigger a resource manager reconnection if the connection
to the resource manager has been lost.
|
static ConfigOption<String> |
WEB_ACCESS_CONTROL_ALLOW_ORIGIN
The config parameter defining the Access-Control-Allow-Origin header for all
responses from the web-frontend.
|
static ConfigOption<Integer> |
WEB_ARCHIVE_COUNT
The config parameter defining the number of archived jobs for the jobmanager.
|
static ConfigOption<Integer> |
WEB_BACKPRESSURE_CLEANUP_INTERVAL
Time after which cached stats are cleaned up if not accessed.
|
static ConfigOption<Integer> |
WEB_BACKPRESSURE_DELAY
Delay between stack trace samples to determine back pressure.
|
static ConfigOption<Integer> |
WEB_BACKPRESSURE_NUM_SAMPLES
Number of stack trace samples to take to determine back pressure.
|
static ConfigOption<Integer> |
WEB_BACKPRESSURE_REFRESH_INTERVAL
Time after which available stats are deprecated and need to be refreshed (by resampling).
|
static ConfigOption<Integer> |
WEB_CHECKPOINTS_HISTORY_SIZE
Config parameter defining the number of checkpoints to remember for recent history.
|
static ConfigOption<String> |
WEB_LOG_PATH
The log file location (may be in /log for standalone but under log directory when using YARN).
|
static ConfigOption<Integer> |
WEB_PORT
The port for the runtime monitor web-frontend server.
|
static ConfigOption<Boolean> |
WEB_SSL_ENABLED
Config parameter to override SSL support for the JobManager Web UI
|
static ConfigOption<Boolean> |
WEB_SUBMIT_ENABLE
Config parameter indicating whether jobs can be uploaded and run from the web-frontend.
|
static ConfigOption<String> |
WEB_TMP_DIR
The config parameter defining the flink web directory to be used by the webmonitor.
|
static ConfigOption<String> |
WEB_UPLOAD_DIR
The config parameter defining the directory for uploading the job jars.
|
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<Integer> JOB_MANAGER_HEAP_MEMORY
public static final ConfigOption<Integer> MAX_ATTEMPTS_HISTORY_SIZE
public static final ConfigOption<String> EXECUTION_FAILOVER_STRATEGY
public static final ConfigOption<Long> RESOURCE_MANAGER_RECONNECT_INTERVAL
public static final ConfigOption<Integer> WEB_PORT
public static final ConfigOption<String> WEB_ACCESS_CONTROL_ALLOW_ORIGIN
public static final ConfigOption<Boolean> WEB_SSL_ENABLED
public static final ConfigOption<String> WEB_TMP_DIR
public static final ConfigOption<String> WEB_UPLOAD_DIR
public static final ConfigOption<Integer> WEB_ARCHIVE_COUNT
public static final ConfigOption<String> WEB_LOG_PATH
public static final ConfigOption<Boolean> WEB_SUBMIT_ENABLE
public static final ConfigOption<Integer> WEB_CHECKPOINTS_HISTORY_SIZE
public static final ConfigOption<Integer> WEB_BACKPRESSURE_CLEANUP_INTERVAL
public static final ConfigOption<Integer> WEB_BACKPRESSURE_REFRESH_INTERVAL
public static final ConfigOption<Integer> WEB_BACKPRESSURE_NUM_SAMPLES
public static final ConfigOption<Integer> WEB_BACKPRESSURE_DELAY
public static final ConfigOption<String> ARCHIVE_DIR
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.