Modifier and Type | Field and Description |
---|---|
static String |
AKKA_ASK_TIMEOUT
Timeout for all blocking calls on the cluster side
|
static String |
AKKA_CLIENT_TIMEOUT
Timeout for all blocking calls on the client side
|
static String |
AKKA_DISPATCHER_THROUGHPUT
Maximum number of messages until another actor is executed by the same thread
|
static String |
AKKA_FRAMESIZE
Maximum framesize of akka messages
|
static String |
AKKA_JVM_EXIT_ON_FATAL_ERROR
Exit JVM on fatal Akka errors
|
static String |
AKKA_LOG_LIFECYCLE_EVENTS
Log lifecycle events
|
static String |
AKKA_LOOKUP_TIMEOUT
Timeout for all blocking calls that look up remote actors
|
static String |
AKKA_STARTUP_TIMEOUT
Timeout for the startup of the actor system
|
static String |
AKKA_TCP_TIMEOUT
Akka TCP timeout
|
static String |
AKKA_TRANSPORT_HEARTBEAT_INTERVAL
Heartbeat interval of the transport failure detector
|
static String |
AKKA_TRANSPORT_HEARTBEAT_PAUSE
Allowed heartbeat pause for the transport failure detector
|
static String |
AKKA_TRANSPORT_THRESHOLD
Detection threshold of transport failure detector
|
static String |
AKKA_WATCH_HEARTBEAT_INTERVAL
Heartbeat interval of watch failure detector
|
static String |
AKKA_WATCH_HEARTBEAT_PAUSE
Allowed heartbeat pause for the watch failure detector
|
static String |
AKKA_WATCH_THRESHOLD
Detection threshold for the phi accrual watch failure detector
|
static String |
BLOB_FETCH_BACKLOG_KEY
The config parameter defining the backlog of BLOB fetches on the JobManager
|
static String |
BLOB_FETCH_CONCURRENT_KEY
The config parameter defining the maximum number of concurrent BLOB fetches that the JobManager serves.
|
static String |
BLOB_FETCH_RETRIES_KEY
The config parameter defining number of retires for failed BLOB fetches.
|
static String |
BLOB_SERVER_PORT
The config parameter defining the server port of the blob service.
|
static String |
BLOB_STORAGE_DIRECTORY_KEY
The config parameter defining the storage directory to be used by the blob server.
|
static String |
CONTAINERIZED_HEAP_CUTOFF_MIN
Minimum amount of heap memory to remove in containers, as a safety margin.
|
static String |
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 String |
DEFAULT_AKKA_ASK_TIMEOUT |
static String |
DEFAULT_AKKA_CLIENT_TIMEOUT |
static int |
DEFAULT_AKKA_DISPATCHER_THROUGHPUT |
static String |
DEFAULT_AKKA_FRAMESIZE |
static boolean |
DEFAULT_AKKA_LOG_LIFECYCLE_EVENTS |
static String |
DEFAULT_AKKA_LOOKUP_TIMEOUT |
static String |
DEFAULT_AKKA_TRANSPORT_HEARTBEAT_INTERVAL |
static String |
DEFAULT_AKKA_TRANSPORT_HEARTBEAT_PAUSE |
static double |
DEFAULT_AKKA_TRANSPORT_THRESHOLD |
static double |
DEFAULT_AKKA_WATCH_THRESHOLD |
static int |
DEFAULT_BLOB_FETCH_BACKLOG
Default BLOB fetch connection backlog.
|
static int |
DEFAULT_BLOB_FETCH_CONCURRENT
Default number of concurrent BLOB fetch operations.
|
static int |
DEFAULT_BLOB_FETCH_RETRIES
Default number of retries for failed BLOB fetches.
|
static String |
DEFAULT_BLOB_SERVER_PORT
Default BLOB server port.
|
static int |
DEFAULT_DELIMITED_FORMAT_MAX_LINE_SAMPLES
The default maximum number of line samples taken by the delimited input format.
|
static int |
DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN
The default maximum sample length before sampling is aborted (2 MiBytes).
|
static int |
DEFAULT_DELIMITED_FORMAT_MIN_LINE_SAMPLES
The default minimum number of line samples taken by the delimited input format.
|
static int |
DEFAULT_EXECUTION_RETRIES
The default number of execution retries.
|
static boolean |
DEFAULT_FILESYSTEM_ALWAYS_CREATE_DIRECTORY
The default behavior for output directory creating (create only directory when parallelism > 1).
|
static boolean |
DEFAULT_FILESYSTEM_OVERWRITE
The default behavior with respect to overwriting existing files (= not overwrite)
|
static String |
DEFAULT_FILESYSTEM_SCHEME
The default filesystem to be used, if no other scheme is specified in the
user-provided URI (= local filesystem)
|
static int |
DEFAULT_FS_STREAM_OPENING_TIMEOUT
The default timeout for filesystem stream opening: infinite (means max long milliseconds).
|
static int |
DEFAULT_JOB_MANAGER_IPC_PORT
The default network port to connect to for communication with the job manager.
|
static int |
DEFAULT_JOB_MANAGER_MAX_ATTEMPTS_HISTORY_SIZE
The default number of prior execution attempt information being stored on
the job manager before the oldest information is deleted.
|
static int |
DEFAULT_JOB_MANAGER_WEB_ARCHIVE_COUNT
The default number of archived jobs for the jobmanager
|
static int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL
Time after which cached stats are cleaned up.
|
static int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_DELAY
Delay between samples to determine back pressure.
|
static int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES
Number of samples to take to determine back pressure.
|
static int |
DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL
Time after which available stats are deprecated and need to be refreshed (by resampling).
|
static boolean |
DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_DISABLE
Default flag to disable checkpoint stats.
|
static int |
DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE
Default number of checkpoints to remember for recent history.
|
static int |
DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT
The config key for the port of the JobManager web frontend.
|
static boolean |
DEFAULT_JOB_MANAGER_WEB_SUBMIT_ENABLED
By default, submitting jobs from the web-frontend is allowed.
|
static long |
DEFAULT_LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL
The default library cache manager cleanup interval in seconds
|
static int |
DEFAULT_LOCAL_NUMBER_JOB_MANAGER |
static int |
DEFAULT_LOCAL_NUMBER_RESOURCE_MANAGER |
static int |
DEFAULT_LOCAL_NUMBER_TASK_MANAGER |
static float |
DEFAULT_MEMORY_MANAGER_MEMORY_FRACTION
The default fraction of the free memory allocated by the task manager's memory manager.
|
static int |
DEFAULT_NETWORK_REQUEST_BACKOFF_INITIAL
Initial backoff for partition requests of input channels.
|
static int |
DEFAULT_NETWORK_REQUEST_BACKOFF_MAX
Maximum backoff for partition requests of input channels.
|
static int |
DEFAULT_PARALLELISM
The default parallelism for operations.
|
static String |
DEFAULT_PARALLELISM_KEY
The config parameter defining the default parallelism for jobs.
|
static String |
DEFAULT_RECOVERY_JOB_MANAGER_PORT
Default port used by the job manager if not in standalone recovery mode.
|
static String |
DEFAULT_RECOVERY_MODE |
static int |
DEFAULT_RESOURCE_MANAGER_IPC_PORT
The default network port of the resource manager.
|
static boolean |
DEFAULT_RUNTIME_HASH_JOIN_BLOOM_FILTERS
Default setting for the switch for hash join bloom filters for spilled partitions.
|
static float |
DEFAULT_SORT_SPILLING_THRESHOLD
The default percentage of the sort memory to be full before data is spilled.
|
static String |
DEFAULT_SORT_SPILLING_THRESHOLD_KEY
Key for the default spilling threshold.
|
static int |
DEFAULT_SPILLING_MAX_FAN
The default value for the maximum spilling fan in/out.
|
static String |
DEFAULT_SPILLING_MAX_FAN_KEY
Parameter for the maximum fan for out-of-core algorithms.
|
static String |
DEFAULT_STATE_BACKEND |
static long |
DEFAULT_TASK_CANCELLATION_INTERVAL_MILLIS
The default interval (in milliseconds) to wait between consecutive task cancellation attempts (= 30000 msec).
|
static long |
DEFAULT_TASK_CANCELLATION_TIMEOUT_MILLIS
Default timeout in milliseconds after which a task cancellation times out
and leads to a fatal TaskManager error.
|
static long |
DEFAULT_TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT
The default for the maximum number of bytes that a checkpoint alignment may buffer.
|
static int |
DEFAULT_TASK_MANAGER_DATA_PORT
The default network port the task manager expects to receive transfer envelopes on.
|
static long |
DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS
The interval (in ms) for the log thread to log the current memory usage.
|
static boolean |
DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD
Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.
|
static String |
DEFAULT_TASK_MANAGER_INITIAL_REGISTRATION_PAUSE
The default task manager's initial registration pause.
|
static int |
DEFAULT_TASK_MANAGER_IPC_PORT
The default network port the task manager expects incoming IPC connections.
|
static String |
DEFAULT_TASK_MANAGER_MAX_REGISTRATION_DURATION
The default task manager's maximum registration duration
|
static String |
DEFAULT_TASK_MANAGER_MAX_REGISTRATION_PAUSE
The default task manager's maximum registration pause.
|
static boolean |
DEFAULT_TASK_MANAGER_MEMORY_PRE_ALLOCATE
The default setting for TaskManager memory eager allocation of managed memory
|
static int |
DEFAULT_TASK_MANAGER_MEMORY_SEGMENT_SIZE
Default size of memory segments in the network stack and the memory manager.
|
static String |
DEFAULT_TASK_MANAGER_NETWORK_DEFAULT_IO_MODE
The implementation to use for spillable/spilled intermediate results, which have both
synchronous and asynchronous implementations: "sync" or "async".
|
static int |
DEFAULT_TASK_MANAGER_NETWORK_NUM_BUFFERS
Default number of buffers used in the network stack.
|
static String |
DEFAULT_TASK_MANAGER_REFUSED_REGISTRATION_PAUSE
The default task manager's refused registration pause.
|
static String |
DEFAULT_TASK_MANAGER_TMP_PATH
The default directory for temporary files of the task manager.
|
static boolean |
DEFAULT_USE_LARGE_RECORD_HANDLER
Whether to use the LargeRecordHandler when spilling.
|
static String |
DEFAULT_YARN_APPLICATION_MASTER_PORT
Deprecated.
|
static int |
DEFAULT_YARN_HEAP_CUTOFF
Minimum amount of memory to subtract from the process memory to get the TaskManager
heap size.
|
static float |
DEFAULT_YARN_HEAP_CUTOFF_RATIO
Relative amount of memory to subtract from Java process memory to get the TaskManager
heap size
|
static String |
DEFAULT_YARN_JOB_MANAGER_PORT
Default port for the application master is 0, which means
the operating system assigns an ephemeral port
|
static int |
DEFAULT_YARN_MIN_HEAP_CUTOFF
Deprecated.
|
static String |
DEFAULT_ZOOKEEPER_CHECKPOINT_COUNTER_PATH |
static String |
DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH |
static int |
DEFAULT_ZOOKEEPER_CLIENT_PORT
ZooKeeper default client port.
|
static int |
DEFAULT_ZOOKEEPER_CONNECTION_TIMEOUT |
static String |
DEFAULT_ZOOKEEPER_DIR_KEY |
static int |
DEFAULT_ZOOKEEPER_INIT_LIMIT
ZooKeeper default init limit.
|
static String |
DEFAULT_ZOOKEEPER_JOBGRAPHS_PATH |
static String |
DEFAULT_ZOOKEEPER_LATCH_PATH |
static String |
DEFAULT_ZOOKEEPER_LEADER_PATH |
static int |
DEFAULT_ZOOKEEPER_LEADER_PORT
ZooKeeper default leader port.
|
static int |
DEFAULT_ZOOKEEPER_MAX_RETRY_ATTEMPTS |
static String |
DEFAULT_ZOOKEEPER_NAMESPACE_KEY |
static int |
DEFAULT_ZOOKEEPER_PEER_PORT
ZooKeeper default peer port.
|
static int |
DEFAULT_ZOOKEEPER_RETRY_WAIT |
static int |
DEFAULT_ZOOKEEPER_SESSION_TIMEOUT |
static int |
DEFAULT_ZOOKEEPER_SYNC_LIMIT
ZooKeeper default sync limit.
|
static String |
DELIMITED_FORMAT_MAX_LINE_SAMPLES_KEY
The maximum number of line samples to be taken by the delimited input format, if no
other value is specified for the data source.
|
static String |
DELIMITED_FORMAT_MAX_SAMPLE_LENGTH_KEY
The maximum length of a single sampled record before the sampling is aborted.
|
static String |
DELIMITED_FORMAT_MIN_LINE_SAMPLES_KEY
The minimum number of line samples to be taken by the delimited input format, if no
other value is specified for the data source.
|
static String |
ENABLE_QUARANTINE_MONITOR
Deprecated.
Only introduced in 1.1.4 to not change the default behaviour
|
static String |
ENV_FLINK_CONF_DIR
The environment variable name which contains the location of the configuration directory
|
static String |
ENV_FLINK_LIB_DIR
The environment variable name which contains the location of the lib folder
|
static String |
EXECUTION_RETRIES_KEY
Deprecated.
The configuration value will be replaced by
RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS
and the corresponding FixedDelayRestartStrategy. |
static String |
EXECUTION_RETRY_DELAY_KEY
Deprecated.
The configuration value will be replaced by
RESTART_STRATEGY_FIXED_DELAY_DELAY
and the corresponding FixedDelayRestartStrategy. |
static String |
FILESYSTEM_DEFAULT_OVERWRITE_KEY
Key to specify whether the file systems should simply overwrite existing files.
|
static String |
FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY_KEY
Key to specify whether the file systems should always create a directory for the output, even with a parallelism of one.
|
static String |
FILESYSTEM_SCHEME
Key to specify the default filesystem to be used by a job.
|
static String |
FLINK_BASE_DIR_PATH_KEY
The key to the Flink base directory path
|
static String |
FLINK_JVM_OPTIONS |
static String |
FS_STREAM_OPENING_TIMEOUT_KEY
The config parameter defining the timeout for filesystem stream opening.
|
static String |
HDFS_DEFAULT_CONFIG
Path to hdfs-defaul.xml file
|
static String |
HDFS_SITE_CONFIG
Path to hdfs-site.xml file
|
static String |
JOB_MANAGER_IPC_ADDRESS_KEY
The config parameter defining the network address to connect to
for communication with the job manager.
|
static String |
JOB_MANAGER_IPC_PORT_KEY
The config parameter defining the network port to connect to
for communication with the job manager.
|
static String |
JOB_MANAGER_MAX_ATTEMPTS_HISTORY_SIZE
The config parameter defining the number of prior execution attempt information being stored
on the job manager before the oldest execution attempt information is deleted.
|
static String |
JOB_MANAGER_WEB_ARCHIVE_COUNT
The config parameter defining the number of archived jobs for the jobmanager
|
static String |
JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL
Time after which cached stats are cleaned up if not accessed.
|
static String |
JOB_MANAGER_WEB_BACK_PRESSURE_DELAY
Delay between stack trace samples to determine back pressure.
|
static String |
JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES
Number of stack trace samples to take to determine back pressure.
|
static String |
JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL
Time after which available stats are deprecated and need to be refreshed (by resampling).
|
static String |
JOB_MANAGER_WEB_CHECKPOINTS_DISABLE
Flag to disable checkpoint stats.
|
static String |
JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE
Config parameter defining the number of checkpoints to remember for recent history.
|
static String |
JOB_MANAGER_WEB_LOG_PATH_KEY
The log file location (may be in /log for standalone but under log directory when using YARN)
|
static String |
JOB_MANAGER_WEB_PORT_KEY
The port for the runtime monitor web-frontend server.
|
static String |
JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY
Config parameter indicating whether jobs can be uploaded and run from the web-frontend.
|
static String |
JOB_MANAGER_WEB_TMPDIR_KEY
The config parameter defining the flink web directory to be used by the webmonitor.
|
static String |
LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL
The config parameter defining the cleanup interval of the library cache manager.
|
static String |
LOCAL_NUMBER_JOB_MANAGER |
static String |
LOCAL_NUMBER_RESOURCE_MANAGER |
static String |
LOCAL_NUMBER_TASK_MANAGER
Sets the number of local task managers
|
static String |
LOCAL_START_WEBSERVER |
static String |
METRICS_REPORTER_CLASS_SUFFIX
The class of the reporter to use.
|
static String |
METRICS_REPORTER_INTERVAL_SUFFIX
The interval between reports.
|
static String |
METRICS_REPORTER_PREFIX
The prefix for per-reporter configs.
|
static String |
METRICS_REPORTERS_LIST
The list of named reporters.
|
static String |
METRICS_SCOPE_DELIMITER
The delimiter used to assemble the metric identifier.
|
static String |
METRICS_SCOPE_NAMING_JM
The scope format string that is applied to all metrics scoped to a JobManager.
|
static String |
METRICS_SCOPE_NAMING_JM_JOB
The scope format string that is applied to all metrics scoped to a job on a JobManager.
|
static String |
METRICS_SCOPE_NAMING_OPERATOR
The scope format string that is applied to all metrics scoped to an operator.
|
static String |
METRICS_SCOPE_NAMING_TASK
The scope format string that is applied to all metrics scoped to a task.
|
static String |
METRICS_SCOPE_NAMING_TM
The scope format string that is applied to all metrics scoped to a TaskManager.
|
static String |
METRICS_SCOPE_NAMING_TM_JOB
The scope format string that is applied to all metrics scoped to a job on a TaskManager.
|
static String |
NETWORK_REQUEST_BACKOFF_INITIAL_KEY
Minimum backoff for partition requests of input channels.
|
static String |
NETWORK_REQUEST_BACKOFF_MAX_KEY |
static String |
PATH_HADOOP_CONFIG
Path to Hadoop configuration
|
static String |
RECOVERY_JOB_DELAY
The time before the JobManager recovers persisted jobs
|
static String |
RECOVERY_JOB_MANAGER_PORT
Ports used by the job manager if not in standalone recovery mode
|
static String |
RECOVERY_MODE
Defines recovery mode used for the cluster execution ("standalone", "zookeeper")
|
static String |
RESOURCE_MANAGER_IPC_PORT_KEY
The config parameter defining the network port to connect to
for communication with the resource manager.
|
static String |
RESTART_STRATEGY
Defines the restart strategy to be used.
|
static String |
RESTART_STRATEGY_FAILURE_RATE_DELAY
Delay between two consecutive restart attempts in FailureRateRestartStrategy.
|
static String |
RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL
Time interval in which greater amount of failures than
RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL causes
job fail in FailureRateRestartStrategy. |
static String |
RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL
Maximum number of restarts in given time interval
RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL before failing a job
in FailureRateRestartStrategy. |
static String |
RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS
Maximum number of attempts the fixed delay restart strategy will try before failing a job.
|
static String |
RESTART_STRATEGY_FIXED_DELAY_DELAY
Delay between two consecutive restart attempts in FixedDelayRestartStrategy.
|
static String |
RUNTIME_HASH_JOIN_BLOOM_FILTERS_KEY
Parameter to switch hash join bloom filters for spilled partitions on and off.
|
static String |
STATE_BACKEND
State backend for checkpoints;
|
static String |
TASK_CANCELLATION_INTERVAL_MILLIS
Time interval between two successive task cancellation attempts in milliseconds.
|
static String |
TASK_CANCELLATION_TIMEOUT_MILLIS
Timeout in milliseconds after which a task cancellation times out and
leads to a fatal TaskManager error.
|
static String |
TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT
The maximum number of bytes that a checkpoint alignment may buffer.
|
static String |
TASK_MANAGER_DATA_PORT_KEY
The config parameter defining the task manager's data port from the configuration.
|
static String |
TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS
The interval (in ms) for the log thread to log the current memory usage.
|
static String |
TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD
Flag indicating whether to start a thread, which repeatedly logs the memory usage of the JVM.
|
static String |
TASK_MANAGER_HOSTNAME_KEY
The config parameter defining the task manager's hostname.
|
static String |
TASK_MANAGER_INITIAL_REGISTRATION_PAUSE
The initial registration pause between two consecutive registration attempts.
|
static String |
TASK_MANAGER_IPC_PORT_KEY
The config parameter defining the task manager's IPC port from the configuration.
|
static String |
TASK_MANAGER_LOG_PATH_KEY
The config parameter defining the taskmanager log file location
|
static String |
TASK_MANAGER_MAX_REGISTARTION_PAUSE
The maximum registration pause between two consecutive registration attempts.
|
static String |
TASK_MANAGER_MAX_REGISTRATION_DURATION
Defines the maximum time it can take for the TaskManager registration.
|
static String |
TASK_MANAGER_MEMORY_FRACTION_KEY
The config parameter defining the fraction of free memory allocated by the memory manager.
|
static String |
TASK_MANAGER_MEMORY_OFF_HEAP_KEY
The config parameter defining the memory allocation method (JVM heap or off-heap).
|
static String |
TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY
The config parameter for specifying whether TaskManager managed memory should be preallocated
when the TaskManager is starting.
|
static String |
TASK_MANAGER_MEMORY_SEGMENT_SIZE_KEY
Config parameter defining the size of memory buffers used by the network stack and the memory manager.
|
static String |
TASK_MANAGER_MEMORY_SIZE_KEY
The config parameter defining the amount of memory to be allocated by the task manager's
memory manager (in megabytes).
|
static String |
TASK_MANAGER_NETWORK_DEFAULT_IO_MODE
The implementation to use for spillable/spilled intermediate results, which have both
synchronous and asynchronous implementations: "sync" or "async".
|
static String |
TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY
The config parameter defining the number of buffers used in the network stack.
|
static String |
TASK_MANAGER_NUM_TASK_SLOTS
The config parameter defining the number of task slots of a task manager.
|
static String |
TASK_MANAGER_REFUSED_REGISTRATION_PAUSE
The pause after a registration has been refused by the job manager before retrying to connect.
|
static String |
TASK_MANAGER_TMP_DIR_KEY
The config parameter defining the directories for temporary files.
|
static String |
USE_LARGE_RECORD_HANDLER_KEY
Whether to use the LargeRecordHandler when spilling.
|
static String |
YARN_APPLICATION_ATTEMPTS
Set the number of retries for failed YARN ApplicationMasters/JobManagers in high
availability mode.
|
static String |
YARN_APPLICATION_MASTER_ENV_PREFIX
Deprecated.
Please use
CONTAINERIZED_MASTER_ENV_PREFIX . |
static String |
YARN_APPLICATION_MASTER_PORT
The config parameter defining the Akka actor system port for the ApplicationMaster and
JobManager
The port can either be a port, such as "9123",
a range of ports: "50100-50200"
or a list of ranges and or points: "50100-50200,50300-50400,51234"
Setting the port to 0 will let the OS choose an available port.
|
static String |
YARN_HEAP_CUTOFF_MIN
Deprecated.
in favor of
#CONTAINERIZED_HEAP_CUTOFF_MIN |
static String |
YARN_HEAP_CUTOFF_RATIO
Deprecated.
in favor of
#CONTAINERIZED_HEAP_CUTOFF_RATIO |
static String |
YARN_HEARTBEAT_DELAY_SECONDS
The heartbeat interval between the Application Master and the YARN Resource Manager.
|
static String |
YARN_MAX_FAILED_CONTAINERS
The maximum number of failed YARN containers before entirely stopping
the YARN session / job on YARN.
|
static String |
YARN_PROPERTIES_FILE_LOCATION
When a Flink job is submitted to YARN, the JobManager's host and the number of available
processing slots is written into a properties file, so that the Flink client is able
to pick those details up.
|
static String |
YARN_REALLOCATE_FAILED_CONTAINERS
Deprecated.
|
static String |
YARN_TASK_MANAGER_ENV_PREFIX
Deprecated.
Please use
CONTAINERIZED_TASK_MANAGER_ENV_PREFIX . |
static String |
YARN_VCORES
The vcores exposed by YYARN.
|
static String |
ZOOKEEPER_CHECKPOINT_COUNTER_PATH
ZooKeeper root path (ZNode) for checkpoint counters.
|
static String |
ZOOKEEPER_CHECKPOINTS_PATH
ZooKeeper root path (ZNode) for completed checkpoints.
|
static String |
ZOOKEEPER_CONNECTION_TIMEOUT |
static String |
ZOOKEEPER_DIR_KEY
ZooKeeper root path.
|
static String |
ZOOKEEPER_JOBGRAPHS_PATH
ZooKeeper root path (ZNode) for job graphs.
|
static String |
ZOOKEEPER_LATCH_PATH |
static String |
ZOOKEEPER_LEADER_PATH |
static String |
ZOOKEEPER_MAX_RETRY_ATTEMPTS |
static String |
ZOOKEEPER_NAMESPACE_KEY |
static String |
ZOOKEEPER_QUORUM_KEY
ZooKeeper servers.
|
static String |
ZOOKEEPER_RECOVERY_PATH
File system state backend base path for recoverable state handles.
|
static String |
ZOOKEEPER_RETRY_WAIT |
static String |
ZOOKEEPER_SESSION_TIMEOUT |
public static final String DEFAULT_PARALLELISM_KEY
@PublicEvolving public static final String RESTART_STRATEGY
@PublicEvolving public static final String RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS
@PublicEvolving public static final String RESTART_STRATEGY_FIXED_DELAY_DELAY
@PublicEvolving public static final String RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL
RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL
before failing a job
in FailureRateRestartStrategy.@PublicEvolving public static final String RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL
RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL
causes
job fail in FailureRateRestartStrategy. It can be specified using Scala's FiniteDuration notation: "1 min", "20 s"@PublicEvolving public static final String RESTART_STRATEGY_FAILURE_RATE_DELAY
@Deprecated @PublicEvolving public static final String EXECUTION_RETRIES_KEY
RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS
and the corresponding FixedDelayRestartStrategy.@Deprecated @PublicEvolving public static final String EXECUTION_RETRY_DELAY_KEY
RESTART_STRATEGY_FIXED_DELAY_DELAY
and the corresponding FixedDelayRestartStrategy.public static final String JOB_MANAGER_IPC_ADDRESS_KEY
public static final String JOB_MANAGER_IPC_PORT_KEY
@PublicEvolving public static final String JOB_MANAGER_MAX_ATTEMPTS_HISTORY_SIZE
public static final String RESOURCE_MANAGER_IPC_PORT_KEY
public static final String BLOB_STORAGE_DIRECTORY_KEY
public static final String BLOB_FETCH_RETRIES_KEY
public static final String BLOB_FETCH_CONCURRENT_KEY
public static final String BLOB_FETCH_BACKLOG_KEY
public static final String BLOB_SERVER_PORT
public static final String LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL
public static final String TASK_MANAGER_HOSTNAME_KEY
public static final String TASK_MANAGER_IPC_PORT_KEY
public static final String TASK_MANAGER_DATA_PORT_KEY
public static final String TASK_MANAGER_TMP_DIR_KEY
public static final String TASK_MANAGER_LOG_PATH_KEY
public static final String TASK_MANAGER_MEMORY_SIZE_KEY
TASK_MANAGER_MEMORY_FRACTION_KEY
.public static final String TASK_MANAGER_MEMORY_FRACTION_KEY
public static final String TASK_MANAGER_MEMORY_OFF_HEAP_KEY
public static final String TASK_MANAGER_MEMORY_PRE_ALLOCATE_KEY
public static final String TASK_MANAGER_NETWORK_NUM_BUFFERS_KEY
public static final String NETWORK_REQUEST_BACKOFF_INITIAL_KEY
public static final String NETWORK_REQUEST_BACKOFF_MAX_KEY
public static final String TASK_MANAGER_MEMORY_SEGMENT_SIZE_KEY
public static final String TASK_MANAGER_NETWORK_DEFAULT_IO_MODE
public static final String TASK_MANAGER_NUM_TASK_SLOTS
public static final String TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD
public static final String TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS
public static final String TASK_MANAGER_MAX_REGISTRATION_DURATION
public static final String TASK_MANAGER_INITIAL_REGISTRATION_PAUSE
public static final String TASK_MANAGER_MAX_REGISTARTION_PAUSE
public static final String TASK_MANAGER_REFUSED_REGISTRATION_PAUSE
@PublicEvolving public static final String TASK_CANCELLATION_INTERVAL_MILLIS
@PublicEvolving public static final String TASK_CANCELLATION_TIMEOUT_MILLIS
@PublicEvolving public static final String TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT
public static final String DEFAULT_SPILLING_MAX_FAN_KEY
public static final String DEFAULT_SORT_SPILLING_THRESHOLD_KEY
public static final String RUNTIME_HASH_JOIN_BLOOM_FILTERS_KEY
public static final String FS_STREAM_OPENING_TIMEOUT_KEY
public static final String USE_LARGE_RECORD_HANDLER_KEY
public static final String CONTAINERIZED_HEAP_CUTOFF_RATIO
public static final String CONTAINERIZED_HEAP_CUTOFF_MIN
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)@Deprecated public static final String ENABLE_QUARANTINE_MONITOR
public static final String YARN_VCORES
@Deprecated public static final String YARN_HEAP_CUTOFF_RATIO
#CONTAINERIZED_HEAP_CUTOFF_RATIO
@Deprecated public static final String YARN_HEAP_CUTOFF_MIN
#CONTAINERIZED_HEAP_CUTOFF_MIN
@Deprecated public static final String YARN_REALLOCATE_FAILED_CONTAINERS
public static final String YARN_MAX_FAILED_CONTAINERS
public static final String YARN_APPLICATION_ATTEMPTS
public static final String YARN_HEARTBEAT_DELAY_SECONDS
public static final String YARN_PROPERTIES_FILE_LOCATION
@Deprecated public static final String YARN_APPLICATION_MASTER_ENV_PREFIX
CONTAINERIZED_MASTER_ENV_PREFIX
.@Deprecated public static final String DEFAULT_YARN_APPLICATION_MASTER_PORT
@Deprecated public static final int DEFAULT_YARN_MIN_HEAP_CUTOFF
@Deprecated public static final String YARN_TASK_MANAGER_ENV_PREFIX
CONTAINERIZED_TASK_MANAGER_ENV_PREFIX
.YARN_APPLICATION_MASTER_ENV_PREFIX
, this configuration prefix allows
setting custom environment variables.public static final String YARN_APPLICATION_MASTER_PORT
public static final String HDFS_DEFAULT_CONFIG
public static final String HDFS_SITE_CONFIG
public static final String PATH_HADOOP_CONFIG
public static final String FILESYSTEM_SCHEME
file:///
, which is the default (see DEFAULT_FILESYSTEM_SCHEME
),
the local filesystem is going to be used to resolve URIs without an explicit scheme.public static final String FILESYSTEM_DEFAULT_OVERWRITE_KEY
public static final String FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY_KEY
public static final String DELIMITED_FORMAT_MAX_LINE_SAMPLES_KEY
public static final String DELIMITED_FORMAT_MIN_LINE_SAMPLES_KEY
public static final String DELIMITED_FORMAT_MAX_SAMPLE_LENGTH_KEY
public static final String JOB_MANAGER_WEB_PORT_KEY
public static final String JOB_MANAGER_WEB_TMPDIR_KEY
public static final String JOB_MANAGER_WEB_ARCHIVE_COUNT
public static final String JOB_MANAGER_WEB_LOG_PATH_KEY
public static final String JOB_MANAGER_WEB_SUBMIT_ENABLED_KEY
public static final String JOB_MANAGER_WEB_CHECKPOINTS_DISABLE
public static final String JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE
public static final String JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL
public static final String JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL
public static final String JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES
public static final String JOB_MANAGER_WEB_BACK_PRESSURE_DELAY
public static final String AKKA_STARTUP_TIMEOUT
public static final String AKKA_TRANSPORT_HEARTBEAT_INTERVAL
public static final String AKKA_TRANSPORT_HEARTBEAT_PAUSE
public static final String AKKA_TRANSPORT_THRESHOLD
public static final String AKKA_WATCH_HEARTBEAT_INTERVAL
public static final String AKKA_WATCH_HEARTBEAT_PAUSE
public static final String AKKA_WATCH_THRESHOLD
public static final String AKKA_TCP_TIMEOUT
public static final String AKKA_FRAMESIZE
public static final String AKKA_DISPATCHER_THROUGHPUT
public static final String AKKA_LOG_LIFECYCLE_EVENTS
public static final String AKKA_ASK_TIMEOUT
public static final String AKKA_LOOKUP_TIMEOUT
public static final String AKKA_CLIENT_TIMEOUT
public static final String AKKA_JVM_EXIT_ON_FATAL_ERROR
public static final String STATE_BACKEND
public static final String FLINK_BASE_DIR_PATH_KEY
public static final String FLINK_JVM_OPTIONS
public static final String RECOVERY_MODE
public static final String RECOVERY_JOB_MANAGER_PORT
public static final String RECOVERY_JOB_DELAY
public static final String ZOOKEEPER_QUORUM_KEY
public static final String ZOOKEEPER_RECOVERY_PATH
public static final String ZOOKEEPER_DIR_KEY
public static final String ZOOKEEPER_NAMESPACE_KEY
public static final String ZOOKEEPER_LATCH_PATH
public static final String ZOOKEEPER_LEADER_PATH
public static final String ZOOKEEPER_JOBGRAPHS_PATH
public static final String ZOOKEEPER_CHECKPOINTS_PATH
public static final String ZOOKEEPER_CHECKPOINT_COUNTER_PATH
public static final String ZOOKEEPER_SESSION_TIMEOUT
public static final String ZOOKEEPER_CONNECTION_TIMEOUT
public static final String ZOOKEEPER_RETRY_WAIT
public static final String ZOOKEEPER_MAX_RETRY_ATTEMPTS
public static final String METRICS_REPORTERS_LIST
metrics.reporters = foo, bar
metrics.reporter.foo.class = org.apache.flink.metrics.reporter.JMXReporter
metrics.reporter.foo.interval = 10
metrics.reporter.bar.class = org.apache.flink.metrics.graphite.GraphiteReporter
metrics.reporter.bar.port = 1337
public static final String METRICS_REPORTER_PREFIX
public static final String METRICS_REPORTER_CLASS_SUFFIX
public static final String METRICS_REPORTER_INTERVAL_SUFFIX
public static final String METRICS_SCOPE_DELIMITER
public static final String METRICS_SCOPE_NAMING_JM
public static final String METRICS_SCOPE_NAMING_TM
public static final String METRICS_SCOPE_NAMING_JM_JOB
public static final String METRICS_SCOPE_NAMING_TM_JOB
public static final String METRICS_SCOPE_NAMING_TASK
public static final String METRICS_SCOPE_NAMING_OPERATOR
public static final int DEFAULT_PARALLELISM
public static final int DEFAULT_EXECUTION_RETRIES
public static final long DEFAULT_LIBRARY_CACHE_MANAGER_CLEANUP_INTERVAL
public static final int DEFAULT_JOB_MANAGER_IPC_PORT
public static final int DEFAULT_JOB_MANAGER_MAX_ATTEMPTS_HISTORY_SIZE
public static final int DEFAULT_RESOURCE_MANAGER_IPC_PORT
public static final int DEFAULT_BLOB_FETCH_RETRIES
public static final int DEFAULT_BLOB_FETCH_CONCURRENT
public static final int DEFAULT_BLOB_FETCH_BACKLOG
public static final String DEFAULT_BLOB_SERVER_PORT
public static final int DEFAULT_TASK_MANAGER_IPC_PORT
0
means that
the TaskManager searches for a free port.public static final int DEFAULT_TASK_MANAGER_DATA_PORT
0
means that
the TaskManager searches for a free port.public static final String DEFAULT_TASK_MANAGER_TMP_PATH
public static final float DEFAULT_MEMORY_MANAGER_MEMORY_FRACTION
public static final int DEFAULT_TASK_MANAGER_NETWORK_NUM_BUFFERS
public static final int DEFAULT_NETWORK_REQUEST_BACKOFF_INITIAL
public static final int DEFAULT_NETWORK_REQUEST_BACKOFF_MAX
public static final int DEFAULT_TASK_MANAGER_MEMORY_SEGMENT_SIZE
public static final String DEFAULT_TASK_MANAGER_NETWORK_DEFAULT_IO_MODE
public static final boolean DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_START_LOG_THREAD
public static final long DEFAULT_TASK_MANAGER_DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS
public static final String DEFAULT_TASK_MANAGER_MAX_REGISTRATION_DURATION
public static final String DEFAULT_TASK_MANAGER_INITIAL_REGISTRATION_PAUSE
public static final String DEFAULT_TASK_MANAGER_MAX_REGISTRATION_PAUSE
public static final String DEFAULT_TASK_MANAGER_REFUSED_REGISTRATION_PAUSE
public static final boolean DEFAULT_TASK_MANAGER_MEMORY_PRE_ALLOCATE
public static final long DEFAULT_TASK_CANCELLATION_INTERVAL_MILLIS
public static final long DEFAULT_TASK_CANCELLATION_TIMEOUT_MILLIS
@PublicEvolving public static final long DEFAULT_TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT
-1
= infinite.public static final boolean DEFAULT_RUNTIME_HASH_JOIN_BLOOM_FILTERS
public static final int DEFAULT_SPILLING_MAX_FAN
public static final float DEFAULT_SORT_SPILLING_THRESHOLD
public static final int DEFAULT_FS_STREAM_OPENING_TIMEOUT
public static final boolean DEFAULT_USE_LARGE_RECORD_HANDLER
public static final int DEFAULT_YARN_HEAP_CUTOFF
public static final float DEFAULT_YARN_HEAP_CUTOFF_RATIO
public static final String DEFAULT_YARN_JOB_MANAGER_PORT
public static final String DEFAULT_FILESYSTEM_SCHEME
public static final boolean DEFAULT_FILESYSTEM_OVERWRITE
public static final boolean DEFAULT_FILESYSTEM_ALWAYS_CREATE_DIRECTORY
public static final int DEFAULT_DELIMITED_FORMAT_MAX_LINE_SAMPLES
public static final int DEFAULT_DELIMITED_FORMAT_MIN_LINE_SAMPLES
public static final int DEFAULT_DELIMITED_FORMAT_MAX_SAMPLE_LEN
public static final int DEFAULT_JOB_MANAGER_WEB_FRONTEND_PORT
-1
disables the web frontend.public static final int DEFAULT_JOB_MANAGER_WEB_ARCHIVE_COUNT
public static final boolean DEFAULT_JOB_MANAGER_WEB_SUBMIT_ENABLED
public static final boolean DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_DISABLE
public static final int DEFAULT_JOB_MANAGER_WEB_CHECKPOINTS_HISTORY_SIZE
public static final int DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_CLEAN_UP_INTERVAL
public static final int DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_REFRESH_INTERVAL
public static final int DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_NUM_SAMPLES
public static final int DEFAULT_JOB_MANAGER_WEB_BACK_PRESSURE_DELAY
public static String DEFAULT_AKKA_TRANSPORT_HEARTBEAT_INTERVAL
public static String DEFAULT_AKKA_TRANSPORT_HEARTBEAT_PAUSE
public static double DEFAULT_AKKA_TRANSPORT_THRESHOLD
public static double DEFAULT_AKKA_WATCH_THRESHOLD
public static int DEFAULT_AKKA_DISPATCHER_THROUGHPUT
public static boolean DEFAULT_AKKA_LOG_LIFECYCLE_EVENTS
public static String DEFAULT_AKKA_FRAMESIZE
public static String DEFAULT_AKKA_ASK_TIMEOUT
public static String DEFAULT_AKKA_LOOKUP_TIMEOUT
public static String DEFAULT_AKKA_CLIENT_TIMEOUT
public static String DEFAULT_STATE_BACKEND
public static final String LOCAL_NUMBER_TASK_MANAGER
public static final int DEFAULT_LOCAL_NUMBER_TASK_MANAGER
public static final String LOCAL_NUMBER_JOB_MANAGER
public static final int DEFAULT_LOCAL_NUMBER_JOB_MANAGER
public static final String LOCAL_NUMBER_RESOURCE_MANAGER
public static final int DEFAULT_LOCAL_NUMBER_RESOURCE_MANAGER
public static final String LOCAL_START_WEBSERVER
public static String DEFAULT_RECOVERY_MODE
public static final String DEFAULT_RECOVERY_JOB_MANAGER_PORT
0
the OS picks a random port port.public static final String DEFAULT_ZOOKEEPER_DIR_KEY
public static final String DEFAULT_ZOOKEEPER_NAMESPACE_KEY
public static final String DEFAULT_ZOOKEEPER_LATCH_PATH
public static final String DEFAULT_ZOOKEEPER_LEADER_PATH
public static final String DEFAULT_ZOOKEEPER_JOBGRAPHS_PATH
public static final String DEFAULT_ZOOKEEPER_CHECKPOINTS_PATH
public static final String DEFAULT_ZOOKEEPER_CHECKPOINT_COUNTER_PATH
public static final int DEFAULT_ZOOKEEPER_SESSION_TIMEOUT
public static final int DEFAULT_ZOOKEEPER_CONNECTION_TIMEOUT
public static final int DEFAULT_ZOOKEEPER_RETRY_WAIT
public static final int DEFAULT_ZOOKEEPER_MAX_RETRY_ATTEMPTS
public static final int DEFAULT_ZOOKEEPER_CLIENT_PORT
public static final int DEFAULT_ZOOKEEPER_INIT_LIMIT
public static final int DEFAULT_ZOOKEEPER_SYNC_LIMIT
public static final int DEFAULT_ZOOKEEPER_PEER_PORT
public static final int DEFAULT_ZOOKEEPER_LEADER_PORT
public static final String ENV_FLINK_CONF_DIR
public static final String ENV_FLINK_LIB_DIR
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.