Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
WebOptions.ACCESS_CONTROL_ALLOW_ORIGIN
The config parameter defining the Access-Control-Allow-Origin header for all
responses from the web-frontend.
|
static ConfigOption<String> |
RestOptions.ADDRESS
The address that should be used by clients to connect to the server.
|
static ConfigOption<String> |
WebOptions.ADDRESS
Config parameter defining the runtime monitor web-frontend server address.
|
static ConfigOption<String> |
JobManagerOptions.ADDRESS
The config parameter defining the network address to connect to
for communication with the job manager.
|
static ConfigOption<String> |
CoreOptions.ALWAYS_PARENT_FIRST_LOADER_PATTERNS
The namespace patterns for classes that are loaded with a preference from the
parent classloader, meaning the application class path, rather than any user code
jar file.
|
static ConfigOption<String> |
CoreOptions.ALWAYS_PARENT_FIRST_LOADER_PATTERNS_ADDITIONAL |
static ConfigOption<Integer> |
WebOptions.ARCHIVE_COUNT
The config parameter defining the number of archived jobs for the jobmanager.
|
static ConfigOption<String> |
JobManagerOptions.ARCHIVE_DIR
The location where the JobManager stores the archives of completed jobs.
|
static ConfigOption<String> |
AkkaOptions.ASK_TIMEOUT
Timeout for akka ask calls.
|
static ConfigOption<Boolean> |
CheckpointingOptions.ASYNC_SNAPSHOTS
Option whether the state backend should use an asynchronous snapshot method where
possible and configurable.
|
static ConfigOption<Long> |
RestOptions.AWAIT_LEADER_TIMEOUT
The time in ms that the client waits for the leader address, e.g., Dispatcher or
WebMonitorEndpoint.
|
static ConfigOption<Integer> |
WebOptions.BACKPRESSURE_CLEANUP_INTERVAL
Time after which cached stats are cleaned up if not accessed.
|
static ConfigOption<Integer> |
WebOptions.BACKPRESSURE_DELAY
Delay between stack trace samples to determine back pressure.
|
static ConfigOption<Integer> |
WebOptions.BACKPRESSURE_NUM_SAMPLES
Number of stack trace samples to take to determine back pressure.
|
static ConfigOption<Integer> |
WebOptions.BACKPRESSURE_REFRESH_INTERVAL
Time after which available stats are deprecated and need to be refreshed (by resampling).
|
static ConfigOption<String> |
RestOptions.BIND_ADDRESS
The address that the server binds itself to.
|
static ConfigOption<String> |
CheckpointingOptions.CHECKPOINTS_DIRECTORY
The default directory used for storing the data files and meta data of checkpoints in a Flink supported filesystem.
|
static ConfigOption<Integer> |
WebOptions.CHECKPOINTS_HISTORY_SIZE
Config parameter defining the number of checkpoints to remember for recent history.
|
static ConfigOption<String> |
CoreOptions.CLASSLOADER_RESOLVE_ORDER
Defines the class resolution strategy when loading classes from user code,
meaning whether to first check the user code jar (
"child-first" ) or
the application classpath ("parent-first" ) |
static ConfigOption<Long> |
BlobServerOptions.CLEANUP_INTERVAL
Cleanup interval of the blob caches at the task managers (in seconds).
|
static ConfigOption<Integer> |
RestOptions.CLIENT_MAX_CONTENT_LENGTH
The maximum content length that the client will handle.
|
static ConfigOption<Integer> |
QueryableStateOptions.CLIENT_NETWORK_THREADS
Number of network (event loop) threads for the KvState client (0 => Use number of available cores).
|
static ConfigOption<Double> |
AkkaOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR |
static ConfigOption<Integer> |
AkkaOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_MAX |
static ConfigOption<Integer> |
AkkaOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_MIN |
static ConfigOption<String> |
AkkaOptions.CLIENT_TIMEOUT
Timeout for all blocking calls on the client side.
|
static ConfigOption<Long> |
RestOptions.CONNECTION_TIMEOUT
The maximum time in ms for the client to establish a TCP connection.
|
static ConfigOption<Integer> |
ResourceManagerOptions.CONTAINERIZED_HEAP_CUTOFF_MIN
Minimum amount of heap memory to remove in containers, as a safety margin.
|
static ConfigOption<Float> |
ResourceManagerOptions.CONTAINERIZED_HEAP_CUTOFF_RATIO
Percentage of heap space to remove from containers (YARN / Mesos), to compensate
for other JVM memory usage.
|
static ConfigOption<Integer> |
TaskManagerOptions.DATA_PORT
The default network port the task manager expects to receive transfer envelopes on.
|
static ConfigOption<Boolean> |
TaskManagerOptions.DATA_SSL_ENABLED
Config parameter to override SSL support for taskmanager's data transport.
|
static ConfigOption<Boolean> |
TaskManagerOptions.DEBUG_MEMORY_LOG |
static ConfigOption<Long> |
TaskManagerOptions.DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS |
static ConfigOption<String> |
CoreOptions.DEFAULT_FILESYSTEM_SCHEME
The default filesystem scheme, used for paths that do not declare a scheme explicitly.
|
static ConfigOption<String> |
ConfigConstants.DEFAULT_JOB_MANAGER_WEB_FRONTEND_ADDRESS
Deprecated.
use
WebOptions.ADDRESS instead |
static ConfigOption<Integer> |
CoreOptions.DEFAULT_PARALLELISM |
static ConfigOption<Integer> |
OptimizerOptions.DELIMITED_FORMAT_MAX_LINE_SAMPLES
The maximum number of line samples taken by the compiler for delimited inputs.
|
static ConfigOption<Integer> |
OptimizerOptions.DELIMITED_FORMAT_MAX_SAMPLE_LEN
The maximal length of a line sample that the compiler takes for delimited inputs.
|
static ConfigOption<Integer> |
OptimizerOptions.DELIMITED_FORMAT_MIN_LINE_SAMPLES
The minimum number of line samples taken by the compiler for delimited inputs.
|
static ConfigOption<Integer> |
AkkaOptions.DISPATCHER_THROUGHPUT
Maximum number of messages until another actor is executed by the same thread.
|
static ConfigOption<String> |
JobManagerOptions.EXECUTION_FAILOVER_STRATEGY
The maximum number of prior execution attempts kept in history.
|
static ConfigOption<Boolean> |
TaskManagerOptions.EXIT_ON_FATAL_AKKA_ERROR
Whether the quarantine monitor for task managers shall be started.
|
static ConfigOption<Integer> |
BlobServerOptions.FETCH_BACKLOG
The config parameter defining the backlog of BLOB fetches on the JobManager.
|
static ConfigOption<Integer> |
BlobServerOptions.FETCH_CONCURRENT
The config parameter defining the maximum number of concurrent BLOB fetches that the JobManager serves.
|
static ConfigOption<Integer> |
BlobServerOptions.FETCH_RETRIES
The config parameter defining number of retires for failed BLOB fetches.
|
static ConfigOption<Boolean> |
CoreOptions.FILESYSTEM_OUTPUT_ALWAYS_CREATE_DIRECTORY
Specifies whether the file systems should always create a directory for the output, even with a parallelism of one.
|
static ConfigOption<Boolean> |
CoreOptions.FILESYTEM_DEFAULT_OVERRIDE
Specifies whether file output writers should overwrite existing files by default.
|
static ConfigOption<String> |
CoreOptions.FLINK_JM_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_JVM_OPTIONS |
static ConfigOption<String> |
CoreOptions.FLINK_LOG_DIR
This options is here only for documentation generation, it is only
evaluated in the shell scripts.
|
static ConfigOption<Integer> |
CoreOptions.FLINK_LOG_MAX
This options is here only for documentation generation, it is only
evaluated in the shell scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_SSH_OPTIONS
This options is here only for documentation generation, it is only
evaluated in the shell scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_TM_JVM_OPTIONS |
static ConfigOption<Double> |
AkkaOptions.FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR |
static ConfigOption<Integer> |
AkkaOptions.FORK_JOIN_EXECUTOR_PARALLELISM_MAX |
static ConfigOption<Integer> |
AkkaOptions.FORK_JOIN_EXECUTOR_PARALLELISM_MIN |
static ConfigOption<String> |
AkkaOptions.FRAMESIZE
Maximum framesize of akka messages.
|
static ConfigOption<Integer> |
CheckpointingOptions.FS_SMALL_FILE_THRESHOLD
The minimum size of state data files.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_CLUSTER_ID
The ID of the Flink cluster, used to separate multiple Flink clusters
Needs to be set for standalone clusters, is automatically inferred in YARN and Mesos.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_JOB_DELAY
The time before a JobManager after a fail over recovers the current jobs.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_JOB_MANAGER_PORT_RANGE
Optional port (range) used by the job manager in high-availability mode.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_MODE
Defines high-availability mode used for the cluster execution.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_STORAGE_PATH
File system path (URI) where Flink persists metadata in high-availability setups.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH
ZooKeeper root path (ZNode) for checkpoint counters.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINTS_PATH
ZooKeeper root path (ZNode) for completed checkpoints.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_JOBGRAPHS_PATH
ZooKeeper root path (ZNode) for job graphs.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_LATCH_PATH |
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_LEADER_PATH |
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_MESOS_WORKERS_PATH
ZooKeeper root path (ZNode) for Mesos workers.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_QUORUM
The ZooKeeper quorum to use, when running Flink in a high-availability mode with ZooKeeper.
|
static ConfigOption<String> |
HighAvailabilityOptions.HA_ZOOKEEPER_ROOT
The root path under which Flink stores its entries in ZooKeeper.
|
static ConfigOption<Boolean> |
AlgorithmOptions.HASH_JOIN_BLOOM_FILTERS |
static ConfigOption<Long> |
HeartbeatManagerOptions.HEARTBEAT_INTERVAL
Time interval for requesting heartbeat from sender side.
|
static ConfigOption<Long> |
HeartbeatManagerOptions.HEARTBEAT_TIMEOUT
Timeout for requesting and receiving heartbeat for both sender and receiver sides.
|
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_DIRS
Comma-separated list of directories which the HistoryServer polls for new archives.
|
static ConfigOption<Long> |
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_REFRESH_INTERVAL
The interval at which the HistoryServer polls
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_DIRS for new archives. |
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_WEB_ADDRESS
The address under which the HistoryServer web-frontend is accessible.
|
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_WEB_DIR
The local directory used by the HistoryServer web-frontend.
|
static ConfigOption<Integer> |
HistoryServerOptions.HISTORY_SERVER_WEB_PORT
The port under which the HistoryServer web-frontend is accessible.
|
static ConfigOption<Long> |
HistoryServerOptions.HISTORY_SERVER_WEB_REFRESH_INTERVAL
The refresh interval for the HistoryServer web-frontend in milliseconds.
|
static ConfigOption<Boolean> |
HistoryServerOptions.HISTORY_SERVER_WEB_SSL_ENABLED
Enables/Disables SSL support for the HistoryServer web-frontend.
|
static ConfigOption<String> |
TaskManagerOptions.HOST
The config parameter defining the task manager's hostname.
|
static ConfigOption<Long> |
RestOptions.IDLENESS_TIMEOUT
The maximum time in ms for a connection to stay idle before failing.
|
static ConfigOption<Boolean> |
CheckpointingOptions.INCREMENTAL_CHECKPOINTS
Option whether the state backend should create incremental checkpoints,
if possible.
|
static ConfigOption<String> |
TaskManagerOptions.INITIAL_REGISTRATION_BACKOFF
The initial registration backoff between two consecutive registration attempts.
|
static ConfigOption<Integer> |
ResourceManagerOptions.IPC_PORT |
static ConfigOption<Integer> |
JobManagerOptions.JOB_MANAGER_HEAP_MEMORY
JVM heap size (in megabytes) for the JobManager.
|
static ConfigOption<Long> |
JobManagerOptions.JOB_STORE_CACHE_SIZE
The job store cache size in bytes which is used to keep completed
jobs in memory.
|
static ConfigOption<Long> |
JobManagerOptions.JOB_STORE_EXPIRATION_TIME
The time in seconds after which a completed job expires and is purged from the job store.
|
static ConfigOption<String> |
ResourceManagerOptions.JOB_TIMEOUT
Timeout for jobs which don't have a job manager as leader assigned.
|
static ConfigOption<Boolean> |
AkkaOptions.JVM_EXIT_ON_FATAL_ERROR
Exit JVM on fatal Akka errors.
|
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_CONTEXTS |
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_KEYTAB |
static ConfigOption<String> |
SecurityOptions.KERBEROS_LOGIN_PRINCIPAL |
static ConfigOption<Boolean> |
SecurityOptions.KERBEROS_LOGIN_USETICKETCACHE |
static ConfigOption<Boolean> |
TaskManagerOptions.KILL_ON_OUT_OF_MEMORY
Whether to kill the TaskManager when the task thread throws an OutOfMemoryError.
|
static ConfigOption<Integer> |
MetricOptions.LATENCY_HISTORY_SIZE
The number of measured latencies to maintain at each operator.
|
static ConfigOption<Long> |
MetricOptions.LATENCY_INTERVAL |
static ConfigOption<String> |
MetricOptions.LATENCY_SOURCE_GRANULARITY |
static ConfigOption<Integer> |
ResourceManagerOptions.LOCAL_NUMBER_RESOURCE_MANAGER |
static ConfigOption<Boolean> |
CheckpointingOptions.LOCAL_RECOVERY
This option configures local recovery for this state backend.
|
static ConfigOption<String> |
CheckpointingOptions.LOCAL_RECOVERY_TASK_MANAGER_STATE_ROOT_DIRS
The config parameter defining the root directories for storing file-based state for local recovery.
|
static ConfigOption<Boolean> |
AkkaOptions.LOG_LIFECYCLE_EVENTS
Log lifecycle events.
|
static ConfigOption<String> |
WebOptions.LOG_PATH
The log file location (may be in /log for standalone but under log directory when using YARN).
|
static ConfigOption<String> |
AkkaOptions.LOOKUP_TIMEOUT
Timeout for all blocking calls that look up remote actors.
|
static ConfigOption<Float> |
TaskManagerOptions.MANAGED_MEMORY_FRACTION
Fraction of free memory allocated by the memory manager if
TaskManagerOptions.MANAGED_MEMORY_SIZE is
not set. |
static ConfigOption<Boolean> |
TaskManagerOptions.MANAGED_MEMORY_PRE_ALLOCATE
Whether TaskManager managed memory should be pre-allocated when the TaskManager is starting.
|
static ConfigOption<Long> |
TaskManagerOptions.MANAGED_MEMORY_SIZE
Amount of memory to be allocated by the task manager's memory manager (in megabytes).
|
static ConfigOption<Integer> |
JobManagerOptions.MAX_ATTEMPTS_HISTORY_SIZE
The maximum number of prior execution attempts kept in history.
|
static ConfigOption<Integer> |
CheckpointingOptions.MAX_RETAINED_CHECKPOINTS
The maximum number of completed checkpoints to retain.
|
static ConfigOption<Boolean> |
TaskManagerOptions.MEMORY_OFF_HEAP
Memory allocation method (JVM heap or off-heap), used for managed memory of the TaskManager
as well as the network buffers.
|
static ConfigOption<Integer> |
TaskManagerOptions.MEMORY_SEGMENT_SIZE
Size of memory buffers used by the network stack and the memory manager (in bytes).
|
static ConfigOption<String> |
CoreOptions.MODE
Switch to select the execution mode.
|
static ConfigOption<Float> |
TaskManagerOptions.NETWORK_BUFFERS_MEMORY_FRACTION
Fraction of JVM memory to use for network buffers.
|
static ConfigOption<Long> |
TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MAX
Maximum memory size for network buffers (in bytes).
|
static ConfigOption<Long> |
TaskManagerOptions.NETWORK_BUFFERS_MEMORY_MIN
Minimum memory size for network buffers (in bytes).
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_BUFFERS_PER_CHANNEL
Number of network buffers to use for each outgoing/incoming channel (subpartition/input channel).
|
static ConfigOption<Boolean> |
TaskManagerOptions.NETWORK_CREDIT_MODEL
Deprecated.
Will be removed for Flink 1.6 when the old code will be dropped in favour of
credit-based flow control.
|
static ConfigOption<Boolean> |
TaskManagerOptions.NETWORK_DETAILED_METRICS
Boolean flag to enable/disable more detailed metrics about inbound/outbound network queue
lengths.
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_EXTRA_BUFFERS_PER_GATE
Number of extra network buffers to use for each outgoing/incoming gate (result partition/input gate).
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_NUM_BUFFERS
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_REQUEST_BACKOFF_INITIAL
Minimum backoff for partition requests of input channels.
|
static ConfigOption<Integer> |
TaskManagerOptions.NETWORK_REQUEST_BACKOFF_MAX
Maximum backoff for partition requests of input channels.
|
static ConfigOption<Integer> |
TaskManagerOptions.NUM_TASK_SLOTS
The config parameter defining the number of task slots of a task manager.
|
static ConfigOption<Integer> |
BlobServerOptions.OFFLOAD_MINSIZE
The minimum size for messages to be offloaded to the BlobServer.
|
static ConfigOption<Integer> |
RestOptions.PORT
The port that the server listens on / the client connects to.
|
static ConfigOption<Integer> |
WebOptions.PORT
Deprecated.
Use
RestOptions.PORT instead |
static ConfigOption<Integer> |
JobManagerOptions.PORT
The config parameter defining the network port to connect to
for communication with the job manager.
|
static ConfigOption<String> |
BlobServerOptions.PORT
The config parameter defining the server port of the blob service.
|
static ConfigOption<Integer> |
QueryableStateOptions.PROXY_ASYNC_QUERY_THREADS
Number of async query threads for the client proxy (0 => #slots).
|
static ConfigOption<Integer> |
QueryableStateOptions.PROXY_NETWORK_THREADS
Number of network (event loop) threads for the client proxy (0 => #slots).
|
static ConfigOption<String> |
QueryableStateOptions.PROXY_PORT_RANGE
The config parameter defining the server port range of the queryable state proxy.
|
static ConfigOption<Long> |
WebOptions.REFRESH_INTERVAL
The config parameter defining the refresh interval for the web-frontend.
|
static ConfigOption<String> |
TaskManagerOptions.REFUSED_REGISTRATION_BACKOFF
The backoff after a registration has been refused by the job manager before retrying to connect.
|
static ConfigOption<String> |
TaskManagerOptions.REGISTRATION_MAX_BACKOFF
The maximum registration backoff between two consecutive registration attempts.
|
static ConfigOption<String> |
TaskManagerOptions.REGISTRATION_TIMEOUT
Defines the timeout it can take for the TaskManager registration.
|
static ConfigOption<String> |
MetricOptions.REPORTER_CLASS |
static ConfigOption<String> |
MetricOptions.REPORTER_CONFIG_PARAMETER |
static ConfigOption<String> |
MetricOptions.REPORTER_INTERVAL |
static ConfigOption<String> |
MetricOptions.REPORTERS_LIST
An optional list of reporter names.
|
static ConfigOption<Long> |
JobManagerOptions.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> |
ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_DELAY
Delay between two consecutive restart attempts in FixedDelayRestartStrategy.
|
static ConfigOption<Long> |
RestOptions.RETRY_DELAY
The time in ms that the client waits between retries.
|
static ConfigOption<Long> |
AkkaOptions.RETRY_GATE_CLOSED_FOR
Milliseconds a gate should be closed for after a remote connection was disconnected.
|
static ConfigOption<Integer> |
RestOptions.RETRY_MAX_ATTEMPTS
The number of retries the client will attempt if a retryable operations fails.
|
static ConfigOption<String> |
CheckpointingOptions.ROCKSDB_LOCAL_DIRECTORIES
The local directory (on the TaskManager) where RocksDB puts its files.
|
static ConfigOption<String> |
TaskManagerOptions.RPC_PORT
The default network port range the task manager expects incoming IPC connections.
|
static ConfigOption<String> |
CheckpointingOptions.SAVEPOINT_DIRECTORY
The default directory for savepoints.
|
static ConfigOption<String> |
MetricOptions.SCOPE_DELIMITER
The delimiter used to assemble the metric identifier.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_JM
The scope format string that is applied to all metrics scoped to a JobManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_JM_JOB
The scope format string that is applied to all metrics scoped to a job on a JobManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_OPERATOR
The scope format string that is applied to all metrics scoped to an operator.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TASK
The scope format string that is applied to all metrics scoped to a task.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TM
The scope format string that is applied to all metrics scoped to a TaskManager.
|
static ConfigOption<String> |
MetricOptions.SCOPE_NAMING_TM_JOB
The scope format string that is applied to all metrics scoped to a job on a TaskManager.
|
static ConfigOption<Integer> |
QueryableStateOptions.SERVER_ASYNC_QUERY_THREADS
Number of async query threads for the KvStateServerHandler (0 => #slots).
|
static ConfigOption<Integer> |
RestOptions.SERVER_MAX_CONTENT_LENGTH
The maximum content length that the server will handle.
|
static ConfigOption<Integer> |
QueryableStateOptions.SERVER_NETWORK_THREADS
Number of network (event loop) threads for the KvState server (0 => #slots).
|
static ConfigOption<Integer> |
RestOptions.SERVER_NUM_THREADS |
static ConfigOption<String> |
QueryableStateOptions.SERVER_PORT_RANGE
The config parameter defining the server port range of the queryable state server.
|
static ConfigOption<Double> |
AkkaOptions.SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR |
static ConfigOption<Integer> |
AkkaOptions.SERVER_SOCKET_WORKER_POOL_SIZE_MAX |
static ConfigOption<Integer> |
AkkaOptions.SERVER_SOCKET_WORKER_POOL_SIZE_MIN |
static ConfigOption<Integer> |
RestOptions.SERVER_THREAD_PRIORITY |
static ConfigOption<Long> |
JobManagerOptions.SLOT_IDLE_TIMEOUT |
static ConfigOption<Long> |
ResourceManagerOptions.SLOT_REQUEST_TIMEOUT
The timeout for a slot request to be discarded, in milliseconds.
|
static ConfigOption<Long> |
JobManagerOptions.SLOT_REQUEST_TIMEOUT |
static ConfigOption<Float> |
AlgorithmOptions.SORT_SPILLING_THRESHOLD |
static ConfigOption<Integer> |
AlgorithmOptions.SPILLING_MAX_FAN |
static ConfigOption<String> |
SecurityOptions.SSL_ALGORITHMS
The standard SSL algorithms to be supported.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_CLOSE_NOTIFY_FLUSH_TIMEOUT
SSL session timeout after flushing the close_notify message.
|
static ConfigOption<Boolean> |
WebOptions.SSL_ENABLED
Config parameter to override SSL support for the JobManager Web UI.
|
static ConfigOption<Boolean> |
AkkaOptions.SSL_ENABLED
Override SSL support for the Akka transport.
|
static ConfigOption<Boolean> |
BlobServerOptions.SSL_ENABLED
Flag to override ssl support for the blob service transport.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_ENABLED
Enable SSL support.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_HANDSHAKE_TIMEOUT
SSL session timeout during handshakes.
|
static ConfigOption<String> |
SecurityOptions.SSL_KEY_PASSWORD
Secret to decrypt the server key.
|
static ConfigOption<String> |
SecurityOptions.SSL_KEYSTORE
The Java keystore file containing the flink endpoint key and certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_KEYSTORE_PASSWORD
Secret to decrypt the keystore file.
|
static ConfigOption<String> |
SecurityOptions.SSL_PROTOCOL
SSL protocol version to be supported.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_SESSION_CACHE_SIZE
SSL session cache size.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_SESSION_TIMEOUT
SSL session timeout.
|
static ConfigOption<String> |
SecurityOptions.SSL_TRUSTSTORE
The truststore file containing the public CA certificates to verify the ssl peers.
|
static ConfigOption<String> |
SecurityOptions.SSL_TRUSTSTORE_PASSWORD
Secret to decrypt the truststore.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_VERIFY_HOSTNAME
Flag to enable/disable hostname verification for the ssl connections.
|
static ConfigOption<String> |
AkkaOptions.STARTUP_TIMEOUT
Timeout for the startup of the actor system.
|
static ConfigOption<String> |
CheckpointingOptions.STATE_BACKEND
The state backend to be used to store and checkpoint state.
|
static ConfigOption<String> |
BlobServerOptions.STORAGE_DIRECTORY
The config parameter defining the storage directory to be used by the blob server.
|
static ConfigOption<Boolean> |
WebOptions.SUBMIT_ENABLE
Config parameter indicating whether jobs can be uploaded and run from the web-frontend.
|
static ConfigOption<Long> |
TaskManagerOptions.TASK_CANCELLATION_INTERVAL
Time interval in milliseconds between two successive task cancellation
attempts.
|
static ConfigOption<Long> |
TaskManagerOptions.TASK_CANCELLATION_TIMEOUT
Timeout in milliseconds after which a task cancellation times out and
leads to a fatal TaskManager error.
|
static ConfigOption<Long> |
TaskManagerOptions.TASK_CANCELLATION_TIMEOUT_TIMERS
This configures how long we wait for the timers to finish all pending timer threads
when the stream task is cancelled .
|
static ConfigOption<Long> |
TaskManagerOptions.TASK_CHECKPOINT_ALIGNMENT_BYTES_LIMIT
The maximum number of bytes that a checkpoint alignment may buffer.
|
static ConfigOption<Integer> |
TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY
JVM heap size (in megabytes) for the TaskManagers.
|
static ConfigOption<Long> |
ResourceManagerOptions.TASK_MANAGER_TIMEOUT
The timeout for an idle task manager to be released, in milliseconds.
|
static ConfigOption<String> |
AkkaOptions.TCP_TIMEOUT
The Akka tcp connection timeout.
|
static ConfigOption<Long> |
WebOptions.TIMEOUT
Timeout for asynchronous operations by the WebRuntimeMonitor in milliseconds.
|
static ConfigOption<String> |
WebOptions.TMP_DIR
The config parameter defining the flink web directory to be used by the webmonitor.
|
static ConfigOption<String> |
CoreOptions.TMP_DIRS
The config parameter defining the directories for temporary files, separated by
",", "|", or the system's
File.pathSeparator . |
static ConfigOption<String> |
AkkaOptions.TRANSPORT_HEARTBEAT_INTERVAL
Heartbeat interval of the transport failure detector.
|
static ConfigOption<String> |
AkkaOptions.TRANSPORT_HEARTBEAT_PAUSE
Allowed heartbeat pause for the transport failure detector.
|
static ConfigOption<Double> |
AkkaOptions.TRANSPORT_THRESHOLD
Detection threshold of transport failure detector.
|
static ConfigOption<String> |
WebOptions.UPLOAD_DIR
The config parameter defining the directory for uploading the job jars.
|
static ConfigOption<String> |
AkkaOptions.WATCH_HEARTBEAT_INTERVAL
The Akka death watch heartbeat interval.
|
static ConfigOption<String> |
AkkaOptions.WATCH_HEARTBEAT_PAUSE
The maximum acceptable Akka death watch heartbeat pause.
|
static ConfigOption<Integer> |
AkkaOptions.WATCH_THRESHOLD
Detection threshold for the phi accrual watch failure detector.
|
static ConfigOption<String> |
HighAvailabilityOptions.ZOOKEEPER_CLIENT_ACL |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_CONNECTION_TIMEOUT |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_MAX_RETRY_ATTEMPTS |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_RETRY_WAIT |
static ConfigOption<String> |
HighAvailabilityOptions.ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH |
static ConfigOption<Boolean> |
SecurityOptions.ZOOKEEPER_SASL_DISABLE |
static ConfigOption<String> |
SecurityOptions.ZOOKEEPER_SASL_LOGIN_CONTEXT_NAME |
static ConfigOption<String> |
SecurityOptions.ZOOKEEPER_SASL_SERVICE_NAME |
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT |
Modifier and Type | Method and Description |
---|---|
<T> ConfigOption<T> |
ConfigOptions.OptionBuilder.defaultValue(T value)
Creates a ConfigOption with the given default value.
|
static ConfigOption<Integer> |
CoreOptions.fileSystemConnectionLimit(String scheme)
The total number of input plus output connections that a file system for the given scheme may open.
|
static ConfigOption<Integer> |
CoreOptions.fileSystemConnectionLimitIn(String scheme)
The total number of input connections that a file system for the given scheme may open.
|
static ConfigOption<Integer> |
CoreOptions.fileSystemConnectionLimitOut(String scheme)
The total number of output connections that a file system for the given scheme may open.
|
static ConfigOption<Long> |
CoreOptions.fileSystemConnectionLimitStreamInactivityTimeout(String scheme)
If any connection limit is configured, this option can be optionally set to define after
which time (in milliseconds) inactive streams are reclaimed.
|
static ConfigOption<Long> |
CoreOptions.fileSystemConnectionLimitTimeout(String scheme)
If any connection limit is configured, this option can be optionally set to define after
which time (in milliseconds) stream opening fails with a timeout exception, if no stream
connection becomes available.
|
ConfigOption<String> |
ConfigOptions.OptionBuilder.noDefaultValue()
Creates a string-valued option with no default value.
|
ConfigOption<T> |
ConfigOption.withDeprecatedKeys(String... deprecatedKeys)
Creates a new config option, using this option's key and default value, and
adding the given deprecated keys.
|
ConfigOption<T> |
ConfigOption.withDescription(String description)
Creates a new config option, using this option's key and default value, and
adding the given description.
|
Modifier and Type | Method and Description |
---|---|
boolean |
DelegatingConfiguration.contains(ConfigOption<?> configOption) |
boolean |
Configuration.contains(ConfigOption<?> configOption)
Checks whether there is an entry for the given config option.
|
boolean |
DelegatingConfiguration.getBoolean(ConfigOption<Boolean> configOption) |
boolean |
Configuration.getBoolean(ConfigOption<Boolean> configOption)
Returns the value associated with the given config option as a boolean.
|
boolean |
DelegatingConfiguration.getBoolean(ConfigOption<Boolean> configOption,
boolean overrideDefault) |
boolean |
Configuration.getBoolean(ConfigOption<Boolean> configOption,
boolean overrideDefault)
Returns the value associated with the given config option as a boolean.
|
double |
DelegatingConfiguration.getDouble(ConfigOption<Double> configOption) |
double |
Configuration.getDouble(ConfigOption<Double> configOption)
Returns the value associated with the given config option as a
double . |
double |
DelegatingConfiguration.getDouble(ConfigOption<Double> configOption,
double overrideDefault) |
double |
Configuration.getDouble(ConfigOption<Double> configOption,
double overrideDefault)
Returns the value associated with the given config option as a
double . |
float |
DelegatingConfiguration.getFloat(ConfigOption<Float> configOption) |
float |
Configuration.getFloat(ConfigOption<Float> configOption)
Returns the value associated with the given config option as a float.
|
float |
DelegatingConfiguration.getFloat(ConfigOption<Float> configOption,
float overrideDefault) |
float |
Configuration.getFloat(ConfigOption<Float> configOption,
float overrideDefault)
Returns the value associated with the given config option as a float.
|
int |
DelegatingConfiguration.getInteger(ConfigOption<Integer> configOption) |
int |
Configuration.getInteger(ConfigOption<Integer> configOption)
Returns the value associated with the given config option as an integer.
|
int |
DelegatingConfiguration.getInteger(ConfigOption<Integer> configOption,
int overrideDefault) |
int |
Configuration.getInteger(ConfigOption<Integer> configOption,
int overrideDefault)
Returns the value associated with the given config option as an integer.
|
long |
DelegatingConfiguration.getLong(ConfigOption<Long> configOption) |
long |
Configuration.getLong(ConfigOption<Long> configOption)
Returns the value associated with the given config option as a long integer.
|
long |
DelegatingConfiguration.getLong(ConfigOption<Long> configOption,
long overrideDefault) |
long |
Configuration.getLong(ConfigOption<Long> configOption,
long overrideDefault)
Returns the value associated with the given config option as a long integer.
|
String |
DelegatingConfiguration.getString(ConfigOption<String> configOption) |
String |
Configuration.getString(ConfigOption<String> configOption)
Returns the value associated with the given config option as a string.
|
String |
DelegatingConfiguration.getString(ConfigOption<String> configOption,
String overrideDefault) |
String |
Configuration.getString(ConfigOption<String> configOption,
String overrideDefault)
Returns the value associated with the given config option as a string.
|
String |
DelegatingConfiguration.getValue(ConfigOption<?> configOption) |
String |
Configuration.getValue(ConfigOption<?> configOption)
Returns the value associated with the given config option as a string.
|
<T> boolean |
DelegatingConfiguration.removeConfig(ConfigOption<T> configOption) |
<T> boolean |
UnmodifiableConfiguration.removeConfig(ConfigOption<T> configOption) |
<T> boolean |
Configuration.removeConfig(ConfigOption<T> configOption)
Removes given config option from the configuration.
|
void |
DelegatingConfiguration.setBoolean(ConfigOption<Boolean> key,
boolean value) |
void |
Configuration.setBoolean(ConfigOption<Boolean> key,
boolean value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setDouble(ConfigOption<Double> key,
double value) |
void |
Configuration.setDouble(ConfigOption<Double> key,
double value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setFloat(ConfigOption<Float> key,
float value) |
void |
Configuration.setFloat(ConfigOption<Float> key,
float value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setInteger(ConfigOption<Integer> key,
int value) |
void |
Configuration.setInteger(ConfigOption<Integer> key,
int value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setLong(ConfigOption<Long> key,
long value) |
void |
Configuration.setLong(ConfigOption<Long> key,
long value)
Adds the given value to the configuration object.
|
void |
DelegatingConfiguration.setString(ConfigOption<String> key,
String value) |
void |
Configuration.setString(ConfigOption<String> key,
String value)
Adds the given value to the configuration object.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
MesosOptions.ARTIFACT_SERVER_PORT
The config parameter defining the Mesos artifact server port to use.
|
static ConfigOption<Boolean> |
MesosOptions.ARTIFACT_SERVER_SSL_ENABLED
Config parameter to override SSL support for the Artifact Server.
|
static ConfigOption<Integer> |
MesosOptions.FAILOVER_TIMEOUT_SECONDS
The failover timeout for the Mesos scheduler, after which running tasks are automatically shut down.
|
static ConfigOption<Integer> |
MesosOptions.INITIAL_TASKS
The initial number of Mesos tasks to allocate.
|
static ConfigOption<String> |
MesosOptions.MASTER_URL
The Mesos master URL.
|
static ConfigOption<Integer> |
MesosOptions.MAX_FAILED_TASKS
The maximum number of failed Mesos tasks before entirely stopping
the Mesos session / job on Mesos.
|
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_NAME |
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_PRINCIPAL |
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_ROLE |
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_SECRET |
static ConfigOption<String> |
MesosOptions.RESOURCEMANAGER_FRAMEWORK_USER |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
PythonOptions.DATA_TMP_DIR
The config parameter defining where the memory-mapped files will be created.
|
static ConfigOption<String> |
PythonOptions.DC_TMP_DIR
The config parameter defining where the flink python library and user supplied files will be uploaded to before
registering them with the Distributed Cache.
|
static ConfigOption<Long> |
PythonOptions.MMAP_FILE_SIZE
The config parameter defining the size of the memory-mapped files, in kb.
|
static ConfigOption<String> |
PythonOptions.PLAN_TMP_DIR
The config parameter defining where temporary plan-related files are stored on the client.
|
static ConfigOption<String> |
PythonOptions.PYTHON_BINARY_PATH
The config parameter defining the path to the python binary to use.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
ClusterEntrypoint.EXECUTION_MODE |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
NettyConfig.CLIENT_CONNECT_TIMEOUT_SECONDS |
static ConfigOption<Integer> |
NettyConfig.CONNECT_BACKLOG |
static ConfigOption<Integer> |
NettyConfig.NUM_ARENAS |
static ConfigOption<Integer> |
NettyConfig.NUM_THREADS_CLIENT |
static ConfigOption<Integer> |
NettyConfig.NUM_THREADS_SERVER |
static ConfigOption<Integer> |
NettyConfig.SEND_RECEIVE_BUFFER_SIZE |
static ConfigOption<String> |
NettyConfig.TRANSPORT_TYPE |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
PythonOptions.DC_TMP_DIR
The config parameter defining where the flink python library and user supplied files will be uploaded to before
registering them with the Distributed Cache.
|
static ConfigOption<String> |
PythonOptions.PLAN_TMP_DIR
The config parameter defining where temporary plan-related files are stored on the client.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
YarnConfigOptions.APP_MASTER_RPC_ADDRESS
The hostname or address where the application master RPC system is listening.
|
static ConfigOption<Integer> |
YarnConfigOptions.APP_MASTER_RPC_PORT
The port where the application master RPC system is listening.
|
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_ATTEMPTS
Set the number of retries for failed YARN ApplicationMasters/JobManagers in high
availability mode.
|
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_MASTER_PORT
The config parameter defining the Akka actor system port for the ApplicationMaster and
JobManager.
|
static ConfigOption<String> |
YarnConfigOptions.APPLICATION_TAGS
A comma-separated list of strings to use as YARN application tags.
|
static ConfigOption<String> |
YarnConfigOptions.CLASSPATH_INCLUDE_USER_JAR
Defines whether user-jars are included in the system class path for per-job-clusters as well as their positioning
in the path.
|
static ConfigOption<Integer> |
YarnConfigOptions.HEARTBEAT_DELAY_SECONDS
The heartbeat interval between the Application Master and the YARN Resource Manager.
|
static ConfigOption<String> |
YarnConfigOptions.MAX_FAILED_CONTAINERS
The maximum number of failed YARN containers before entirely stopping
the YARN session / job on YARN.
|
static ConfigOption<String> |
YarnConfigOptions.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 ConfigOption<Integer> |
YarnConfigOptions.VCORES
The vcores exposed by YARN.
|
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.