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<org.apache.flink.configuration.MemorySize> |
BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_AVG_DATA_VOLUME_PER_TASK |
|
static ConfigOption<Integer> |
BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_DEFAULT_SOURCE_PARALLELISM |
|
static ConfigOption<Boolean> |
BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_ENABLED |
|
static ConfigOption<Integer> |
BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_MAX_PARALLELISM |
|
static ConfigOption<Integer> |
BatchExecutionOptions.ADAPTIVE_AUTO_PARALLELISM_MIN_PARALLELISM |
|
static ConfigOption<String> |
JobManagerOptions.ADDRESS |
The config parameter defining the network address to connect to for communication with the
job manager.
|
static ConfigOption<String> |
RestOptions.ADDRESS |
The address that should be used by clients to connect to the server.
|
static ConfigOption<Duration> |
CheckpointingOptions.ALIGNED_CHECKPOINT_TIMEOUT |
|
static ConfigOption<Boolean> |
PipelineOptions.ALLOW_UNALIGNED_SOURCE_SPLITS |
Will be removed in future Flink releases.
|
static ConfigOption<String> |
CoreOptions.ALLOWED_FALLBACK_FILESYSTEMS |
|
static ConfigOption<List<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<List<String>> |
CoreOptions.ALWAYS_PARENT_FIRST_LOADER_PATTERNS_ADDITIONAL |
|
static ConfigOption<Boolean> |
StateRecoveryOptions.APPROXIMATE_LOCAL_RECOVERY |
Access to this option is officially only supported via org.apache.flink.runtime.jobgraph.CheckpointConfig#enableApproximateLocalRecovery(boolean),
but there is no good reason behind this.
|
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<Duration> |
RpcOptions.ASK_TIMEOUT_DURATION |
Timeout for Pekko ask calls.
|
static ConfigOption<Duration> |
RestOptions.ASYNC_OPERATION_STORE_DURATION |
|
static ConfigOption<Integer> |
ExecutionOptions.ASYNC_STATE_ACTIVE_BUFFER_SIZE |
The size of buffer under async state execution.
|
static ConfigOption<Long> |
ExecutionOptions.ASYNC_STATE_ACTIVE_BUFFER_TIMEOUT |
The timeout of buffer triggering in milliseconds.
|
static ConfigOption<Integer> |
ExecutionOptions.ASYNC_STATE_TOTAL_BUFFER_SIZE |
The max limit of in-flight records number in async state execution, 'in-flight' refers to the
records that have entered the operator but have not yet been processed and emitted to the
downstream.
|
static ConfigOption<Boolean> |
DeploymentOptions.ATTACHED |
|
static ConfigOption<Boolean> |
PipelineOptions.AUTO_GENERATE_UIDS |
|
static ConfigOption<Duration> |
PipelineOptions.AUTO_WATERMARK_INTERVAL |
|
static ConfigOption<Duration> |
RestOptions.AWAIT_LEADER_TIMEOUT |
The time in ms that the client waits for the leader address, e.g., Dispatcher or
WebMonitorEndpoint.
|
static ConfigOption<BatchShuffleMode> |
ExecutionOptions.BATCH_SHUFFLE_MODE |
|
static ConfigOption<String> |
RestOptions.BIND_ADDRESS |
The address that the server binds itself to.
|
static ConfigOption<String> |
JobManagerOptions.BIND_HOST |
The local address of the network interface that the job manager binds to.
|
static ConfigOption<String> |
TaskManagerOptions.BIND_HOST |
The local address of the network interface that the task manager binds to.
|
static ConfigOption<String> |
RestOptions.BIND_PORT |
The port range that the server could bind itself to.
|
static ConfigOption<Duration> |
BatchExecutionOptions.BLOCK_SLOW_NODE_DURATION |
|
static ConfigOption<Boolean> |
TaskManagerOptions.BUFFER_DEBLOAT_ENABLED |
|
static ConfigOption<Duration> |
TaskManagerOptions.BUFFER_DEBLOAT_PERIOD |
The period between recalculation the relevant size of the buffer.
|
static ConfigOption<Integer> |
TaskManagerOptions.BUFFER_DEBLOAT_SAMPLES |
The number of samples requires for the buffer size adjustment.
|
static ConfigOption<Duration> |
TaskManagerOptions.BUFFER_DEBLOAT_TARGET |
The total time for which automated adjusted buffers should be fully consumed.
|
static ConfigOption<Integer> |
TaskManagerOptions.BUFFER_DEBLOAT_THRESHOLD_PERCENTAGES |
Difference between the new and the old buffer size for applying the new value(in percent).
|
static ConfigOption<Duration> |
ExecutionOptions.BUFFER_TIMEOUT |
|
static ConfigOption<Boolean> |
ExecutionOptions.BUFFER_TIMEOUT_ENABLED |
|
static ConfigOption<Integer> |
RestOptions.CACHE_CHECKPOINT_STATISTICS_SIZE |
Maximum number of entries in the checkpoint statistics cache.
|
static ConfigOption<Duration> |
RestOptions.CACHE_CHECKPOINT_STATISTICS_TIMEOUT |
Duration from write, after which cached checkpoints statistics are cleaned up.
|
static ConfigOption<List<String>> |
PipelineOptions.CACHED_FILES |
|
static ConfigOption<Boolean> |
WebOptions.CANCEL_ENABLE |
Config parameter indicating whether jobs can be canceled from the web-frontend.
|
static ConfigOption<Boolean> |
RpcOptions.CAPTURE_ASK_CALLSTACK |
Flag whether to capture call stacks for RPC ask calls.
|
static ConfigOption<Duration> |
SlowTaskDetectorOptions.CHECK_INTERVAL |
|
static ConfigOption<Boolean> |
CoreOptions.CHECK_LEAKED_CLASSLOADER |
|
static ConfigOption<Long> |
StateRecoveryOptions.CHECKPOINT_ID_OF_IGNORED_IN_FLIGHT_DATA |
|
static ConfigOption<TraceOptions.CheckpointSpanDetailLevel> |
TraceOptions.CHECKPOINT_SPAN_DETAIL_LEVEL |
The detail level for reporting checkpoint spans.
|
static ConfigOption<String> |
CheckpointingOptions.CHECKPOINT_STORAGE |
The checkpoint storage used to checkpoint state for recovery.
|
static ConfigOption<CheckpointingMode> |
CheckpointingOptions.CHECKPOINTING_CONSISTENCY_MODE |
The checkpointing mode (exactly-once vs. at-least-once).
|
static ConfigOption<Duration> |
CheckpointingOptions.CHECKPOINTING_INTERVAL |
|
static ConfigOption<Duration> |
CheckpointingOptions.CHECKPOINTING_INTERVAL_DURING_BACKLOG |
|
static ConfigOption<Duration> |
CheckpointingOptions.CHECKPOINTING_TIMEOUT |
|
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<List<String>> |
PipelineOptions.CLASSPATHS |
A list of URLs that are added to the classpath of each user code classloader of the program.
|
static ConfigOption<Boolean> |
CheckpointingOptions.CLEANER_PARALLEL_MODE |
|
static ConfigOption<Long> |
BlobServerOptions.CLEANUP_INTERVAL |
Cleanup interval of the blob caches at the task managers (in seconds).
|
static ConfigOption<String> |
CleanupOptions.CLEANUP_STRATEGY |
|
static ConfigOption<Duration> |
CleanupOptions.CLEANUP_STRATEGY_EXPONENTIAL_DELAY_INITIAL_BACKOFF |
|
static ConfigOption<Integer> |
CleanupOptions.CLEANUP_STRATEGY_EXPONENTIAL_DELAY_MAX_ATTEMPTS |
|
static ConfigOption<Duration> |
CleanupOptions.CLEANUP_STRATEGY_EXPONENTIAL_DELAY_MAX_BACKOFF |
|
static ConfigOption<Integer> |
CleanupOptions.CLEANUP_STRATEGY_FIXED_DELAY_ATTEMPTS |
|
static ConfigOption<Duration> |
CleanupOptions.CLEANUP_STRATEGY_FIXED_DELAY_DELAY |
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.CLIENT_CONNECT_TIMEOUT_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 |
Deprecated.
Number of network (event loop) threads for the KvState client (0 => Use number of available
cores).
|
static ConfigOption<Double> |
RpcOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_FACTOR |
|
static ConfigOption<Integer> |
RpcOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_MAX |
|
static ConfigOption<Integer> |
RpcOptions.CLIENT_SOCKET_WORKER_POOL_SIZE_MIN |
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.CLIENT_TCP_KEEP_COUNT |
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.CLIENT_TCP_KEEP_IDLE_SECONDS |
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.CLIENT_TCP_KEEP_INTERVAL_SECONDS |
|
static ConfigOption<ExecutionConfig.ClosureCleanerLevel> |
PipelineOptions.CLOSURE_CLEANER_LEVEL |
|
static ConfigOption<Integer> |
ClusterOptions.CLUSTER_IO_EXECUTOR_POOL_SIZE |
|
static ConfigOption<Duration> |
ClusterOptions.CLUSTER_SERVICES_SHUTDOWN_TIMEOUT |
|
static ConfigOption<Integer> |
TaskManagerOptions.COLLECT_PORT |
The default port that CollectSinkFunction$ServerThread is using.
|
static ConfigOption<Integer> |
SinkOptions.COMMITTER_RETRIES |
The number of retries on a committable (e.g., transaction) before Flink application fails and
potentially restarts.
|
static ConfigOption<String> |
DeploymentOptionsInternal.CONF_DIR |
|
static ConfigOption<Integer> |
BlobServerOptions.CONNECT_TIMEOUT |
The connection timeout in milliseconds for the blob client.
|
static ConfigOption<Duration> |
RestOptions.CONNECTION_TIMEOUT |
The maximum time in ms for the client to establish a TCP connection.
|
static ConfigOption<Double> |
TaskManagerOptions.CPU_CORES |
This config option describes number of cpu cores of task executors.
|
static ConfigOption<Boolean> |
CheckpointingOptions.CREATE_CHECKPOINT_SUB_DIR |
Whether to create sub-directories named by job id to store the data files and meta data of
checkpoints.
|
static ConfigOption<String> |
NettyShuffleEnvironmentOptions.DATA_BIND_PORT |
The local network port that the task manager listen at for data exchange.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.DATA_PORT |
The default network port the task manager expects to receive transfer envelopes on.
|
static ConfigOption<Boolean> |
NettyShuffleEnvironmentOptions.DATA_SSL_ENABLED |
Config parameter to override SSL support for taskmanager's data transport.
|
static ConfigOption<Boolean> |
TaskManagerOptions.DEBUG_MEMORY_LOG |
|
static ConfigOption<Duration> |
TaskManagerOptions.DEBUG_MEMORY_USAGE_LOG_INTERVAL_MS |
|
static ConfigOption<Duration> |
ResourceManagerOptions.DECLARE_NEEDED_RESOURCE_DELAY |
|
static ConfigOption<String> |
CoreOptions.DEFAULT_FILESYSTEM_SCHEME |
The default filesystem scheme, used for paths that do not declare a scheme explicitly.
|
static ConfigOption<Integer> |
CoreOptions.DEFAULT_PARALLELISM |
|
static ConfigOption<Boolean> |
SecurityOptions.DELEGATION_TOKEN_PROVIDER_ENABLED |
|
static ConfigOption<Boolean> |
SecurityOptions.DELEGATION_TOKENS_ENABLED |
|
static ConfigOption<Duration> |
SecurityOptions.DELEGATION_TOKENS_RENEWAL_RETRY_BACKOFF |
|
static ConfigOption<Double> |
SecurityOptions.DELEGATION_TOKENS_RENEWAL_TIME_RATIO |
|
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> |
RpcOptions.DISPATCHER_THROUGHPUT |
Maximum number of messages until another actor is executed by the same thread.
|
static ConfigOption<Boolean> |
CheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH |
|
static ConfigOption<Boolean> |
RestOptions.ENABLE_FLAMEGRAPH |
Enables the experimental flame graph feature.
|
static ConfigOption<Boolean> |
RestOptions.ENABLE_PROFILER |
Enables the experimental profiler feature.
|
static ConfigOption<Boolean> |
QueryableStateOptions.ENABLE_QUERYABLE_STATE_PROXY_SERVER |
Deprecated.
Option whether the queryable state proxy and server should be enabled where possible and
configurable.
|
static ConfigOption<Boolean> |
StateChangelogOptions.ENABLE_STATE_CHANGE_LOG |
Whether to enable state change log.
|
static ConfigOption<Boolean> |
CheckpointingOptions.ENABLE_UNALIGNED |
Enables unaligned checkpoints, which greatly reduce checkpointing times under backpressure.
|
static ConfigOption<Boolean> |
CheckpointingOptions.ENABLE_UNALIGNED_INTERRUPTIBLE_TIMERS |
Allows unaligned checkpoints to skip timers that are currently being fired.
|
static ConfigOption<Duration> |
ClusterOptions.ERROR_REGISTRATION_DELAY |
|
static ConfigOption<String> |
JobManagerOptions.EXECUTION_FAILOVER_STRATEGY |
This option specifies the failover strategy, i.e. how the job computation recovers from task
failures.
|
static ConfigOption<Duration> |
SlowTaskDetectorOptions.EXECUTION_TIME_BASELINE_LOWER_BOUND |
|
static ConfigOption<Double> |
SlowTaskDetectorOptions.EXECUTION_TIME_BASELINE_MULTIPLIER |
|
static ConfigOption<Double> |
SlowTaskDetectorOptions.EXECUTION_TIME_BASELINE_RATIO |
|
static ConfigOption<Long> |
ExternalResourceOptions.EXTERNAL_RESOURCE_AMOUNT |
The amount for the external resource specified by >resource_name< per TaskExecutor.
|
static ConfigOption<String> |
ExternalResourceOptions.EXTERNAL_RESOURCE_DRIVER_FACTORY_CLASS |
Defines the factory class name for the external resource identified by >resource_name<.
|
static ConfigOption<String> |
ExternalResourceOptions.EXTERNAL_RESOURCE_DRIVER_PARAM |
The naming pattern of custom config options for the external resource specified by
>resource_name<.
|
static ConfigOption<List<String>> |
ExternalResourceOptions.EXTERNAL_RESOURCE_LIST |
List of the resource_name of all external resources with delimiter ";", e.g.
|
static ConfigOption<ExternalizedCheckpointRetention> |
CheckpointingOptions.EXTERNALIZED_CHECKPOINT_RETENTION |
|
static ConfigOption<Boolean> |
CoreOptions.FAIL_ON_USER_CLASS_LOADING_METASPACE_OOM |
|
static ConfigOption<String> |
JobManagerOptions.FAILURE_ENRICHERS_LIST |
Flag indicating whether JobManager should load available Failure Enricher plugins at startup.
|
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> |
CheckpointingOptions.FILE_MERGING_ACROSS_BOUNDARY |
Whether to allow merging data of multiple checkpoints into one physical file.
|
static ConfigOption<Boolean> |
CheckpointingOptions.FILE_MERGING_ENABLED |
Whether to enable merging multiple checkpoint files into one, which will greatly reduce the
number of small checkpoint files.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
CheckpointingOptions.FILE_MERGING_MAX_FILE_SIZE |
The max size of a physical file for merged checkpoints.
|
static ConfigOption<Float> |
CheckpointingOptions.FILE_MERGING_MAX_SPACE_AMPLIFICATION |
Space amplification stands for the magnification of the occupied space compared to the amount
of valid data.
|
static ConfigOption<Integer> |
CheckpointingOptions.FILE_MERGING_MAX_SUBTASKS_PER_FILE |
The upper limit of the file pool size based on the number of subtasks within each TM (only
for merging private state at Task Manager level).
|
static ConfigOption<Boolean> |
CheckpointingOptions.FILE_MERGING_POOL_BLOCKING |
Whether to use Blocking or Non-Blocking pool for merging physical files.
|
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<Duration> |
RestOptions.FLAMEGRAPH_CLEANUP_INTERVAL |
"Time after which cached stats are cleaned up if not accessed.
|
static ConfigOption<Duration> |
RestOptions.FLAMEGRAPH_DELAY |
Delay between individual stack trace samples taken for building a FlameGraph.
|
static ConfigOption<Integer> |
RestOptions.FLAMEGRAPH_NUM_SAMPLES |
Number of samples to take to build a FlameGraph.
|
static ConfigOption<Duration> |
RestOptions.FLAMEGRAPH_REFRESH_INTERVAL |
Time after which available stats are deprecated and need to be refreshed (by resampling).
|
static ConfigOption<Integer> |
RestOptions.FLAMEGRAPH_STACK_TRACE_DEPTH |
Maximum depth of stack traces used to create FlameGraphs.
|
static ConfigOption<String> |
CoreOptions.FLINK_CLI_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_DEFAULT_JM_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_DEFAULT_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_DEFAULT_TM_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_HADOOP_CONF_DIR |
This option is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_HBASE_CONF_DIR |
This option is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_HS_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_JAVA_HOME |
|
static ConfigOption<String> |
CoreOptions.FLINK_JM_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_LOG_DIR |
This option is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_LOG_LEVEL |
This option is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<Integer> |
CoreOptions.FLINK_LOG_MAX |
This option is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_PID_DIR |
The config parameter defining the directory for Flink PID file. see:
bin/config.sh#KEY_ENV_PID_DIR and bin/config.sh#DEFAULT_ENV_PID_DIR
|
static ConfigOption<String> |
CoreOptions.FLINK_SQL_GATEWAY_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_SSH_OPTIONS |
This option is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<Boolean> |
CoreOptions.FLINK_STD_REDIRECT_TO_FILE |
This option is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<String> |
CoreOptions.FLINK_TM_JVM_OPTIONS |
|
static ConfigOption<String> |
CoreOptions.FLINK_YARN_CONF_DIR |
This option is here only for documentation generation, it is only evaluated in the shell
scripts.
|
static ConfigOption<Duration> |
JobEventStoreOptions.FLUSH_INTERVAL |
|
static ConfigOption<Boolean> |
PipelineOptions.FORCE_AVRO |
|
static ConfigOption<Boolean> |
PipelineOptions.FORCE_KRYO |
|
static ConfigOption<Boolean> |
PipelineOptions.FORCE_KRYO_AVRO |
|
static ConfigOption<Boolean> |
RpcOptions.FORCE_RPC_INVOCATION_SERIALIZATION |
|
static ConfigOption<Boolean> |
CheckpointingOptions.FORCE_UNALIGNED |
|
static ConfigOption<Double> |
RpcOptions.FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR |
|
static ConfigOption<Integer> |
RpcOptions.FORK_JOIN_EXECUTOR_PARALLELISM_MAX |
|
static ConfigOption<Integer> |
RpcOptions.FORK_JOIN_EXECUTOR_PARALLELISM_MIN |
|
static ConfigOption<String> |
RpcOptions.FRAMESIZE |
Maximum framesize of Pekko messages.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.FRAMEWORK_HEAP_MEMORY |
Framework Heap Memory size for TaskExecutors.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.FRAMEWORK_OFF_HEAP_MEMORY |
Framework Off-Heap Memory size for TaskExecutors.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
CheckpointingOptions.FS_SMALL_FILE_THRESHOLD |
The minimum size of state data files.
|
static ConfigOption<Duration> |
TaskManagerOptions.FS_STREAM_OPENING_TIME_OUT |
|
static ConfigOption<Integer> |
CheckpointingOptions.FS_WRITE_BUFFER_SIZE |
The default size of the write buffer for the checkpoint streams that write to file systems.
|
static ConfigOption<Boolean> |
PipelineOptions.GENERIC_TYPES |
|
static ConfigOption<Map<String,String>> |
PipelineOptions.GLOBAL_JOB_PARAMETERS |
|
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.
|
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_EXECUTION_PLANS_PATH |
ZooKeeper root path (ZNode) for execution plans.
|
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> |
ClusterOptions.HALT_ON_FATAL_ERROR |
|
static ConfigOption<Boolean> |
AlgorithmOptions.HASH_JOIN_BLOOM_FILTERS |
|
static ConfigOption<Duration> |
HeartbeatManagerOptions.HEARTBEAT_INTERVAL |
Time interval for requesting heartbeat from sender side.
|
static ConfigOption<Integer> |
HeartbeatManagerOptions.HEARTBEAT_RPC_FAILURE_THRESHOLD |
|
static ConfigOption<Duration> |
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<Duration> |
HistoryServerOptions.HISTORY_SERVER_ARCHIVE_REFRESH_INTERVAL |
|
static ConfigOption<Boolean> |
HistoryServerOptions.HISTORY_SERVER_CLEANUP_EXPIRED_JOBS |
If this option is enabled then deleted job archives are also deleted from HistoryServer.
|
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_JOBMANAGER_LOG_URL_PATTERN |
Pattern of the log URL of JobManager.
|
static ConfigOption<Integer> |
HistoryServerOptions.HISTORY_SERVER_RETAINED_JOBS |
|
static ConfigOption<Duration> |
HistoryServerOptions.HISTORY_SERVER_RETAINED_TTL |
|
static ConfigOption<String> |
HistoryServerOptions.HISTORY_SERVER_TASKMANAGER_LOG_URL_PATTERN |
Pattern of the log URL of TaskManager.
|
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<Duration> |
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 external address of the network interface where the TaskManager is exposed.
|
static ConfigOption<String> |
TaskManagerOptions.HOST_BIND_POLICY |
The config parameter for automatically defining the TaskManager's binding address, if TaskManagerOptions.HOST configuration option is not set.
|
static ConfigOption<JobManagerOptions.HybridPartitionDataConsumeConstraint> |
JobManagerOptions.HYBRID_PARTITION_DATA_CONSUME_CONSTRAINT |
|
static ConfigOption<Duration> |
RestOptions.IDLENESS_TIMEOUT |
The maximum time in ms for a connection to stay idle before failing.
|
static ConfigOption<Boolean> |
CheckpointingOptions.INCREMENTAL_CHECKPOINTS |
Option whether to create incremental checkpoints, if possible.
|
static ConfigOption<Duration> |
ClusterOptions.INITIAL_REGISTRATION_TIMEOUT |
|
static ConfigOption<ClusterOptions.UserSystemExitMode> |
ClusterOptions.INTERCEPT_USER_SYSTEM_EXIT |
|
static ConfigOption<Integer> |
ResourceManagerOptions.IPC_PORT |
Defines the network port to connect to for communication with the resource manager.
|
static ConfigOption<List<String>> |
PipelineOptions.JARS |
A list of jar files that contain the user-defined function (UDF) classes and all classes used
from within the UDFs.
|
static ConfigOption<String> |
JMXServerOptions.JMX_SERVER_PORT |
Port configured to enable JMX server for metrics and debugging.
|
static ConfigOption<List<String>> |
DeploymentOptions.JOB_LISTENERS |
|
static ConfigOption<Integer> |
JobManagerOptions.JOB_MANAGER_FUTURE_POOL_SIZE |
|
static ConfigOption<Integer> |
JobManagerOptions.JOB_MANAGER_IO_POOL_SIZE |
|
static ConfigOption<String> |
ClusterOptions.JOB_MANAGER_PROCESS_WORKING_DIR_BASE |
|
static ConfigOption<String> |
JobManagerOptions.JOB_MANAGER_RESOURCE_ID |
The JobManager's ResourceID.
|
static ConfigOption<Boolean> |
BatchExecutionOptions.JOB_RECOVERY_ENABLED |
|
static ConfigOption<Duration> |
BatchExecutionOptions.JOB_RECOVERY_PREVIOUS_WORKER_RECOVERY_TIMEOUT |
|
static ConfigOption<Duration> |
BatchExecutionOptions.JOB_RECOVERY_SNAPSHOT_MIN_PAUSE |
|
static ConfigOption<List<String>> |
DeploymentOptions.JOB_STATUS_CHANGED_LISTENERS |
|
static ConfigOption<List<MetricOptions.JobStatusMetrics>> |
MetricOptions.JOB_STATUS_METRICS |
Controls which job status metrics will be exposed.
|
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<Integer> |
JobManagerOptions.JOB_STORE_MAX_CAPACITY |
The max number of completed jobs that can be kept in the job store.
|
static ConfigOption<JobManagerOptions.JobStoreType> |
JobManagerOptions.JOB_STORE_TYPE |
Config parameter determining the job store implementation in session cluster.
|
static ConfigOption<Duration> |
ResourceManagerOptions.JOB_TIMEOUT |
Timeout for jobs which don't have a job manager as leader assigned.
|
static ConfigOption<Boolean> |
JobManagerOptions.JVM_DIRECT_MEMORY_LIMIT_ENABLED |
Off-heap Memory size for the JobManager.
|
static ConfigOption<Boolean> |
RpcOptions.JVM_EXIT_ON_FATAL_ERROR |
Exit JVM on fatal Pekko errors.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
JobManagerOptions.JVM_HEAP_MEMORY |
JVM Heap Memory size for the JobManager.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
JobManagerOptions.JVM_METASPACE |
JVM Metaspace Size for the JobManager.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.JVM_METASPACE |
JVM Metaspace Size for the TaskExecutors.
|
static ConfigOption<Float> |
JobManagerOptions.JVM_OVERHEAD_FRACTION |
Fraction of Total Process Memory to be reserved for JVM Overhead.
|
static ConfigOption<Float> |
TaskManagerOptions.JVM_OVERHEAD_FRACTION |
Fraction of Total Process Memory to be reserved for JVM Overhead.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
JobManagerOptions.JVM_OVERHEAD_MAX |
Max JVM Overhead size for the TaskExecutors.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.JVM_OVERHEAD_MAX |
Max JVM Overhead size for the TaskExecutors.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
JobManagerOptions.JVM_OVERHEAD_MIN |
Min JVM Overhead size for the JobManager.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.JVM_OVERHEAD_MIN |
Min JVM Overhead size for the TaskExecutors.
|
static ConfigOption<List<String>> |
SecurityOptions.KERBEROS_HADOOP_FILESYSTEMS_TO_ACCESS |
|
static ConfigOption<String> |
SecurityOptions.KERBEROS_KRB5_PATH |
|
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<Duration> |
SecurityOptions.KERBEROS_RELOGIN_PERIOD |
|
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<Duration> |
MetricOptions.LATENCY_INTERVAL |
|
static ConfigOption<String> |
MetricOptions.LATENCY_SOURCE_GRANULARITY |
|
static ConfigOption<Boolean> |
StateLatencyTrackOptions.LATENCY_TRACK_ENABLED |
|
static ConfigOption<Integer> |
StateLatencyTrackOptions.LATENCY_TRACK_HISTORY_SIZE |
|
static ConfigOption<Integer> |
StateLatencyTrackOptions.LATENCY_TRACK_SAMPLE_INTERVAL |
|
static ConfigOption<Boolean> |
StateLatencyTrackOptions.LATENCY_TRACK_STATE_NAME_AS_VARIABLE |
|
static ConfigOption<Boolean> |
CheckpointingOptions.LOCAL_BACKUP_ENABLED |
This option configures local backup for the state backend, which indicates whether to make
backup checkpoint on local disk.
|
static ConfigOption<Boolean> |
StateRecoveryOptions.LOCAL_RECOVERY |
This option configures local recovery for the state backend, which indicates whether to
recovery from local snapshot.
|
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> |
RpcOptions.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<Duration> |
RpcOptions.LOOKUP_TIMEOUT_DURATION |
Timeout for all blocking calls that look up remote actors.
|
static ConfigOption<Map<String,String>> |
TaskManagerOptions.MANAGED_MEMORY_CONSUMER_WEIGHTS |
Weights of managed memory consumers.
|
static ConfigOption<Float> |
TaskManagerOptions.MANAGED_MEMORY_FRACTION |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.MANAGED_MEMORY_SIZE |
Managed Memory size for TaskExecutors.
|
static ConfigOption<Integer> |
StateChangelogOptions.MATERIALIZATION_MAX_FAILURES_ALLOWED |
|
static ConfigOption<Integer> |
JobManagerOptions.MAX_ATTEMPTS_HISTORY_SIZE |
The maximum number of historical execution attempts kept in history.
|
static ConfigOption<Integer> |
CheckpointingOptions.MAX_CONCURRENT_CHECKPOINTS |
|
static ConfigOption<Integer> |
WebOptions.MAX_EXCEPTION_HISTORY_SIZE |
The maximum number of failures kept in the exception history.
|
static ConfigOption<Integer> |
PipelineOptions.MAX_PARALLELISM |
|
static ConfigOption<Duration> |
RestOptions.MAX_PROFILING_DURATION |
Maximum profiling duration for profiling function.
|
static ConfigOption<Integer> |
RestOptions.MAX_PROFILING_HISTORY_SIZE |
Maximum history size of profiling list.
|
static ConfigOption<Duration> |
ClusterOptions.MAX_REGISTRATION_TIMEOUT |
|
static ConfigOption<Integer> |
CheckpointingOptions.MAX_RETAINED_CHECKPOINTS |
The maximum number of completed checkpoints to retain.
|
static ConfigOption<Integer> |
ResourceManagerOptions.MAX_SLOT_NUM |
|
static ConfigOption<Double> |
ResourceManagerOptions.MAX_TOTAL_CPU |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
ResourceManagerOptions.MAX_TOTAL_MEM |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.MEMORY_SEGMENT_SIZE |
Size of memory buffers used by the network stack and the memory manager.
|
static ConfigOption<Duration> |
MetricOptions.METRIC_FETCHER_UPDATE_INTERVAL |
The config parameter defining the update interval for the metric fetcher used by the web UI
in milliseconds.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.MIN_MEMORY_SEGMENT_SIZE |
Minimum possible size of memory buffers used by the network stack and the memory manager.
|
static ConfigOption<Integer> |
JobManagerOptions.MIN_PARALLELISM_INCREASE |
Deprecated.
|
static ConfigOption<Duration> |
CheckpointingOptions.MIN_PAUSE_BETWEEN_CHECKPOINTS |
|
static ConfigOption<Integer> |
ResourceManagerOptions.MIN_SLOT_NUM |
|
static ConfigOption<Double> |
ResourceManagerOptions.MIN_TOTAL_CPU |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
ResourceManagerOptions.MIN_TOTAL_MEM |
|
static ConfigOption<Integer> |
TaskManagerOptions.MINI_CLUSTER_NUM_TASK_MANAGERS |
|
static ConfigOption<String> |
PipelineOptions.NAME |
The job name used for printing and logging.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.NETWORK_BATCH_SHUFFLE_READ_MEMORY |
Size of direct memory used by batch shuffle for shuffle data read (currently only used by
sort-shuffle and hybrid shuffle).
|
static ConfigOption<Duration> |
NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_REQUEST_TIMEOUT |
The timeout for requesting buffers for each channel.
|
static ConfigOption<Boolean> |
NettyShuffleEnvironmentOptions.NETWORK_DETAILED_METRICS |
Boolean flag to enable/disable more detailed metrics about inbound/outbound network queue
lengths.
|
static ConfigOption<String> |
NettyShuffleEnvironmentOptions.NETWORK_HYBRID_SHUFFLE_EXTERNAL_REMOTE_TIER_FACTORY_CLASS_NAME |
The option to configure the tiered factory creator remote class name for hybrid shuffle.
|
static ConfigOption<String> |
NettyShuffleEnvironmentOptions.NETWORK_HYBRID_SHUFFLE_REMOTE_STORAGE_BASE_PATH |
The option to configure the base remote storage path for hybrid shuffle.
|
static ConfigOption<Float> |
TaskManagerOptions.NETWORK_MEMORY_FRACTION |
Fraction of Total Flink Memory to be used as Network Memory.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.NETWORK_MEMORY_MAX |
Max Network Memory size for TaskExecutors.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.NETWORK_MEMORY_MIN |
Min Network Memory size for TaskExecutors.
|
static ConfigOption<Duration> |
NettyShuffleEnvironmentOptions.NETWORK_PARTITION_REQUEST_TIMEOUT |
The timeout for partition request listener in result partition manager.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_READ_MAX_REQUIRED_BUFFERS_PER_GATE |
The maximum number of network read buffers that are required by an input gate.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_REQUEST_BACKOFF_INITIAL |
Minimum backoff for partition requests of input channels.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_REQUEST_BACKOFF_MAX |
Maximum backoff for partition requests of input channels.
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_RETRIES |
|
static ConfigOption<Integer> |
NettyShuffleEnvironmentOptions.NETWORK_SORT_SHUFFLE_MIN_BUFFERS |
Minimum number of network buffers required per blocking result partition for sort-shuffle.
|
static ConfigOption<Integer> |
TaskManagerOptions.NUM_TASK_SLOTS |
The config parameter defining the number of task slots of a task manager.
|
static ConfigOption<Boolean> |
PipelineOptions.OBJECT_REUSE |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
JobManagerOptions.OFF_HEAP_MEMORY |
Off-heap Memory size for the JobManager.
|
static ConfigOption<Integer> |
BlobServerOptions.OFFLOAD_MINSIZE |
The minimum size for messages to be offloaded to the BlobServer.
|
static ConfigOption<Boolean> |
PipelineOptions.OPERATOR_CHAINING |
|
static ConfigOption<Boolean> |
PipelineOptions.OPERATOR_CHAINING_CHAIN_OPERATORS_WITH_DIFFERENT_MAX_PARALLELISM |
|
static ConfigOption<Map<String,String>> |
PipelineOptions.PARALLELISM_OVERRIDES |
|
static ConfigOption<Boolean> |
JobManagerOptions.PARTITION_RELEASE_DURING_JOB_EXECUTION |
Config parameter controlling whether partitions should already be released during the job
execution.
|
static ConfigOption<String> |
RestOptions.PATH |
The path that should be used by clients to interact with the server.
|
static ConfigOption<Boolean> |
StateChangelogOptions.PERIODIC_MATERIALIZATION_ENABLED |
|
static ConfigOption<Duration> |
StateChangelogOptions.PERIODIC_MATERIALIZATION_INTERVAL |
|
static ConfigOption<String> |
PipelineOptionsInternal.PIPELINE_FIXED_JOB_ID |
|
static ConfigOption<List<String>> |
CoreOptions.PLUGIN_ALWAYS_PARENT_FIRST_LOADER_PATTERNS |
|
static ConfigOption<List<String>> |
CoreOptions.PLUGIN_ALWAYS_PARENT_FIRST_LOADER_PATTERNS_ADDITIONAL |
|
static ConfigOption<String> |
BlobServerOptions.PORT |
The config parameter defining the server port of the blob service.
|
static ConfigOption<Integer> |
JobManagerOptions.PORT |
The config parameter defining the network port to connect to for communication with the job
manager.
|
static ConfigOption<Integer> |
RestOptions.PORT |
The port that the REST client connects to and the REST server binds to if RestOptions.BIND_PORT
has not been specified.
|
static ConfigOption<String> |
ClusterOptions.PROCESS_WORKING_DIR_BASE |
|
static ConfigOption<String> |
RestOptions.PROFILING_RESULT_DIR |
Directory for storing the profiling results.
|
static ConfigOption<Boolean> |
DeploymentOptions.PROGRAM_CONFIG_ENABLED |
|
static ConfigOption<List<String>> |
DeploymentOptions.PROGRAM_CONFIG_WILDCARDS |
|
static ConfigOption<Integer> |
QueryableStateOptions.PROXY_ASYNC_QUERY_THREADS |
Deprecated.
Number of async query threads for the client proxy (0 => #slots).
|
static ConfigOption<Integer> |
QueryableStateOptions.PROXY_NETWORK_THREADS |
Deprecated.
Number of network (event loop) threads for the client proxy (0 => #slots).
|
static ConfigOption<String> |
QueryableStateOptions.PROXY_PORT_RANGE |
Deprecated.
The config parameter defining the server port range of the queryable state proxy.
|
static ConfigOption<String> |
MetricOptions.QUERY_SERVICE_PORT |
The default network port range for Flink's internal metric query service.
|
static ConfigOption<Integer> |
MetricOptions.QUERY_SERVICE_THREAD_PRIORITY |
The thread priority for Flink's internal metric query service.
|
static ConfigOption<Integer> |
ResourceManagerOptions.REDUNDANT_TASK_MANAGER_NUM |
The number of redundant task managers.
|
static ConfigOption<Duration> |
WebOptions.REFRESH_INTERVAL |
The config parameter defining the refresh interval for the web-frontend in milliseconds.
|
static ConfigOption<Duration> |
ClusterOptions.REFUSED_REGISTRATION_DELAY |
|
static ConfigOption<Duration> |
TaskManagerOptions.REGISTRATION_TIMEOUT |
Defines the timeout it can take for the TaskManager registration.
|
static ConfigOption<Double> |
RpcOptions.REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_FACTOR |
|
static ConfigOption<Integer> |
RpcOptions.REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MAX |
|
static ConfigOption<Integer> |
RpcOptions.REMOTE_FORK_JOIN_EXECUTOR_PARALLELISM_MIN |
|
static ConfigOption<Map<String,String>> |
EventOptions.REPORTER_ADDITIONAL_VARIABLES |
|
static ConfigOption<Map<String,String>> |
MetricOptions.REPORTER_ADDITIONAL_VARIABLES |
|
static ConfigOption<Map<String,String>> |
TraceOptions.REPORTER_ADDITIONAL_VARIABLES |
|
static ConfigOption<String> |
EventOptions.REPORTER_CONFIG_PARAMETER |
|
static ConfigOption<String> |
MetricOptions.REPORTER_CONFIG_PARAMETER |
|
static ConfigOption<String> |
TraceOptions.REPORTER_CONFIG_PARAMETER |
|
static ConfigOption<String> |
EventOptions.REPORTER_EXCLUDED_VARIABLES |
|
static ConfigOption<String> |
MetricOptions.REPORTER_EXCLUDED_VARIABLES |
|
static ConfigOption<String> |
TraceOptions.REPORTER_EXCLUDED_VARIABLES |
|
static ConfigOption<List<String>> |
EventOptions.REPORTER_EXCLUDES |
|
static ConfigOption<List<String>> |
MetricOptions.REPORTER_EXCLUDES |
|
static ConfigOption<List<String>> |
TraceOptions.REPORTER_EXCLUDES |
|
static ConfigOption<String> |
EventOptions.REPORTER_FACTORY_CLASS |
|
static ConfigOption<String> |
MetricOptions.REPORTER_FACTORY_CLASS |
|
static ConfigOption<String> |
TraceOptions.REPORTER_FACTORY_CLASS |
|
static ConfigOption<List<String>> |
EventOptions.REPORTER_INCLUDES |
|
static ConfigOption<List<String>> |
MetricOptions.REPORTER_INCLUDES |
|
static ConfigOption<List<String>> |
TraceOptions.REPORTER_INCLUDES |
|
static ConfigOption<Duration> |
MetricOptions.REPORTER_INTERVAL |
|
static ConfigOption<String> |
EventOptions.REPORTER_SCOPE_DELIMITER |
|
static ConfigOption<String> |
MetricOptions.REPORTER_SCOPE_DELIMITER |
|
static ConfigOption<String> |
TraceOptions.REPORTER_SCOPE_DELIMITER |
|
static ConfigOption<String> |
EventOptions.REPORTERS_LIST |
An optional list of reporter names.
|
static ConfigOption<String> |
MetricOptions.REPORTERS_LIST |
An optional list of reporter names.
|
static ConfigOption<Duration> |
ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY |
|
static ConfigOption<Boolean> |
WebOptions.RESCALE_ENABLE |
Config parameter indicating whether jobs can be rescaled from the web-frontend.
|
static ConfigOption<Duration> |
ResourceManagerOptions.RESOURCE_MANAGER_PREVIOUS_WORKER_RECOVERY_TIMEOUT |
Timeout for ResourceManager to recover all the previous attempts workers.
|
static ConfigOption<Duration> |
JobManagerOptions.RESOURCE_STABILIZATION_TIMEOUT |
Deprecated.
|
static ConfigOption<Duration> |
JobManagerOptions.RESOURCE_WAIT_TIMEOUT |
Deprecated.
|
static ConfigOption<String> |
RestartStrategyOptions.RESTART_STRATEGY |
|
static ConfigOption<Integer> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_ATTEMPTS |
|
static ConfigOption<Double> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_BACKOFF_MULTIPLIER |
|
static ConfigOption<Duration> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_INITIAL_BACKOFF |
|
static ConfigOption<Double> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_JITTER_FACTOR |
|
static ConfigOption<Duration> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_MAX_BACKOFF |
|
static ConfigOption<Duration> |
RestartStrategyOptions.RESTART_STRATEGY_EXPONENTIAL_DELAY_RESET_BACKOFF_THRESHOLD |
|
static ConfigOption<Duration> |
RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_DELAY |
|
static ConfigOption<Duration> |
RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_FAILURE_RATE_INTERVAL |
|
static ConfigOption<Integer> |
RestartStrategyOptions.RESTART_STRATEGY_FAILURE_RATE_MAX_FAILURES_PER_INTERVAL |
|
static ConfigOption<Integer> |
RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS |
|
static ConfigOption<Duration> |
RestartStrategyOptions.RESTART_STRATEGY_FIXED_DELAY_DELAY |
|
static ConfigOption<RecoveryClaimMode> |
StateRecoveryOptions.RESTORE_MODE |
Describes the mode how Flink should restore from the given savepoint or retained checkpoint.
|
static ConfigOption<Boolean> |
JobManagerOptions.RETRIEVE_TASK_MANAGER_HOSTNAME |
Flag indicating whether JobManager would retrieve canonical host name of TaskManager during
registration.
|
static ConfigOption<Duration> |
RestOptions.RETRY_DELAY |
The time in ms that the client waits between retries.
|
static ConfigOption<Long> |
RpcOptions.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<Integer> |
JobManagerOptions.RPC_BIND_PORT |
The local port that the job manager binds to.
|
static ConfigOption<Integer> |
TaskManagerOptions.RPC_BIND_PORT |
The local port that the task manager binds to.
|
static ConfigOption<String> |
TaskManagerOptions.RPC_PORT |
The default network port range the task manager expects incoming IPC connections.
|
static ConfigOption<org.apache.flink.api.common.RuntimeExecutionMode> |
ExecutionOptions.RUNTIME_MODE |
|
static ConfigOption<String> |
CheckpointingOptions.SAVEPOINT_DIRECTORY |
The default directory for savepoints.
|
static ConfigOption<Boolean> |
StateRecoveryOptions.SAVEPOINT_IGNORE_UNCLAIMED_STATE |
A flag indicating if we allow Flink to skip savepoint state that cannot be restored, e.g.
|
static ConfigOption<String> |
StateRecoveryOptions.SAVEPOINT_PATH |
The path to a savepoint that will be used to bootstrap the pipeline's state.
|
static ConfigOption<JobManagerOptions.SchedulerType> |
JobManagerOptions.SCHEDULER |
Config parameter determining the scheduler implementation.
|
static ConfigOption<Duration> |
JobManagerOptions.SCHEDULER_EXECUTING_COOLDOWN_AFTER_RESCALING |
|
static ConfigOption<Duration> |
JobManagerOptions.SCHEDULER_EXECUTING_RESOURCE_STABILIZATION_TIMEOUT |
|
static ConfigOption<SchedulerExecutionMode> |
JobManagerOptions.SCHEDULER_MODE |
|
static ConfigOption<Boolean> |
JobManagerOptions.SCHEDULER_PREFER_MINIMAL_TASKMANAGERS_ENABLED |
|
static ConfigOption<Integer> |
JobManagerOptions.SCHEDULER_RESCALE_TRIGGER_MAX_CHECKPOINT_FAILURES |
|
static ConfigOption<Duration> |
JobManagerOptions.SCHEDULER_RESCALE_TRIGGER_MAX_DELAY |
|
static ConfigOption<Duration> |
JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MAX |
Deprecated.
|
static ConfigOption<Duration> |
JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MIN |
Deprecated.
|
static ConfigOption<Duration> |
JobManagerOptions.SCHEDULER_SUBMISSION_RESOURCE_STABILIZATION_TIMEOUT |
|
static ConfigOption<Duration> |
JobManagerOptions.SCHEDULER_SUBMISSION_RESOURCE_WAIT_TIMEOUT |
|
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_JM_OPERATOR |
The scope format string that is applied to all metrics scoped to the components running on a
JobManager of an operator.
|
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<List<String>> |
SecurityOptions.SECURITY_CONTEXT_FACTORY_CLASSES |
|
static ConfigOption<List<String>> |
SecurityOptions.SECURITY_MODULE_FACTORY_CLASSES |
|
static ConfigOption<List<String>> |
PipelineOptions.SERIALIZATION_CONFIG |
|
static ConfigOption<Integer> |
QueryableStateOptions.SERVER_ASYNC_QUERY_THREADS |
Deprecated.
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 |
Deprecated.
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 |
Deprecated.
The config parameter defining the server port range of the queryable state server.
|
static ConfigOption<Double> |
RpcOptions.SERVER_SOCKET_WORKER_POOL_SIZE_FACTOR |
|
static ConfigOption<Integer> |
RpcOptions.SERVER_SOCKET_WORKER_POOL_SIZE_MAX |
|
static ConfigOption<Integer> |
RpcOptions.SERVER_SOCKET_WORKER_POOL_SIZE_MIN |
|
static ConfigOption<Integer> |
RestOptions.SERVER_THREAD_PRIORITY |
|
static ConfigOption<NettyShuffleEnvironmentOptions.CompressionCodec> |
NettyShuffleEnvironmentOptions.SHUFFLE_COMPRESSION_CODEC |
The codec to be used when compressing shuffle data.
|
static ConfigOption<Boolean> |
DeploymentOptions.SHUTDOWN_IF_ATTACHED |
|
static ConfigOption<Boolean> |
DeploymentOptions.SHUTDOWN_ON_APPLICATION_FINISH |
|
static ConfigOption<Boolean> |
StateSizeTrackOptions.SIZE_TRACK_ENABLED |
|
static ConfigOption<Integer> |
StateSizeTrackOptions.SIZE_TRACK_HISTORY_SIZE |
|
static ConfigOption<Integer> |
StateSizeTrackOptions.SIZE_TRACK_SAMPLE_INTERVAL |
|
static ConfigOption<Boolean> |
StateSizeTrackOptions.SIZE_TRACK_STATE_NAME_AS_VARIABLE |
|
static ConfigOption<Duration> |
JobManagerOptions.SLOT_IDLE_TIMEOUT |
The timeout in milliseconds for a idle slot in Slot Pool.
|
static ConfigOption<Duration> |
JobManagerOptions.SLOT_REQUEST_MAX_INTERVAL |
|
static ConfigOption<Duration> |
JobManagerOptions.SLOT_REQUEST_TIMEOUT |
The timeout in milliseconds for requesting a slot from Slot Pool.
|
static ConfigOption<Duration> |
TaskManagerOptions.SLOT_TIMEOUT |
Timeout for identifying inactive slots.
|
static ConfigOption<Boolean> |
ExecutionOptions.SNAPSHOT_COMPRESSION |
Should be moved to CheckpointingOptions along with
ExecutionConfig#useSnapshotCompression, which should be put into CheckpointConfig.
|
static ConfigOption<Integer> |
BlobServerOptions.SO_TIMEOUT |
The socket timeout in milliseconds for the blob client.
|
static ConfigOption<Boolean> |
ExecutionOptions.SORT_INPUTS |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
ExecutionOptions.SORT_KEYED_PARTITION_MEMORY |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
ExecutionOptions.SORT_PARTITION_MEMORY |
|
static ConfigOption<Float> |
AlgorithmOptions.SORT_SPILLING_THRESHOLD |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
ExecutionOptions.SORTED_INPUTS_MEMORY |
|
static ConfigOption<Boolean> |
BatchExecutionOptions.SPECULATIVE_ENABLED |
|
static ConfigOption<Integer> |
BatchExecutionOptions.SPECULATIVE_MAX_CONCURRENT_EXECUTIONS |
|
static ConfigOption<Integer> |
AlgorithmOptions.SPILLING_MAX_FAN |
|
static ConfigOption<String> |
SecurityOptions.SSL_ALGORITHMS |
The standard SSL algorithms to be supported.
|
static ConfigOption<Boolean> |
BlobServerOptions.SSL_ENABLED |
Flag to override ssl support for the blob service transport.
|
static ConfigOption<Boolean> |
RpcOptions.SSL_ENABLED |
Override SSL support for the Pekko transport.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_CERT_FINGERPRINT |
For internal SSL, the sha1 fingerprint of the internal certificate to verify the client.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_INTERNAL_CLOSE_NOTIFY_FLUSH_TIMEOUT |
SSL session timeout after flushing the close_notify message.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_INTERNAL_ENABLED |
Enable SSL for internal communication (pekko rpc, netty data transport, blob server).
|
static ConfigOption<Integer> |
SecurityOptions.SSL_INTERNAL_HANDSHAKE_TIMEOUT |
SSL session timeout during handshakes.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_KEY_PASSWORD |
For internal SSL, the password to decrypt the private key.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_KEYSTORE |
For internal SSL, the Java keystore file containing the private key and certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_KEYSTORE_PASSWORD |
For internal SSL, the password to decrypt the keystore file containing the certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_KEYSTORE_TYPE |
For internal SSL, the type of the keystore.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_INTERNAL_SESSION_CACHE_SIZE |
SSL session cache size.
|
static ConfigOption<Integer> |
SecurityOptions.SSL_INTERNAL_SESSION_TIMEOUT |
SSL session timeout.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_TRUSTSTORE |
For internal SSL, the truststore file containing the public CA certificates to verify the ssl
peers.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_TRUSTSTORE_PASSWORD |
For internal SSL, the secret to decrypt the truststore.
|
static ConfigOption<String> |
SecurityOptions.SSL_INTERNAL_TRUSTSTORE_TYPE |
For internal SSL, the type of the truststore.
|
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<String> |
SecurityOptions.SSL_PROVIDER |
SSL engine provider.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_REST_AUTHENTICATION_ENABLED |
Enable mututal SSL authentication for external REST endpoints.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_CERT_FINGERPRINT |
For external (REST) SSL, the sha1 fingerprint of the rest client certificate to verify.
|
static ConfigOption<Boolean> |
SecurityOptions.SSL_REST_ENABLED |
Enable SSL for external REST endpoints.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_KEY_PASSWORD |
For external (REST) SSL, the password to decrypt the private key.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_KEYSTORE |
For external (REST) SSL, the Java keystore file containing the private key and certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_KEYSTORE_PASSWORD |
For external (REST) SSL, the password to decrypt the keystore file containing the
certificate.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_KEYSTORE_TYPE |
For external (REST) SSL, the type of the keystore.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_TRUSTSTORE |
For external (REST) SSL, the truststore file containing the public CA certificates to verify
the ssl peers.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_TRUSTSTORE_PASSWORD |
For external (REST) SSL, the secret to decrypt the truststore.
|
static ConfigOption<String> |
SecurityOptions.SSL_REST_TRUSTSTORE_TYPE |
For external (REST) SSL, the type of the truststore.
|
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<Duration> |
ResourceManagerOptions.STANDALONE_CLUSTER_STARTUP_PERIOD_TIME |
Time in milliseconds of the start-up period of a standalone cluster.
|
static ConfigOption<Double> |
ResourceManagerOptions.START_WORKER_MAX_FAILURE_RATE |
The maximum number of start worker failures (Native Kubernetes / Yarn) per minute before
pausing requesting new workers.
|
static ConfigOption<Duration> |
ResourceManagerOptions.START_WORKER_RETRY_INTERVAL |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.STARTING_MEMORY_SEGMENT_SIZE |
Starting size of memory buffers used by the network stack and the memory manager.
|
static ConfigOption<Duration> |
RpcOptions.STARTUP_TIMEOUT |
Timeout for the startup of the actor system.
|
static ConfigOption<String> |
StateBackendOptions.STATE_BACKEND |
The checkpoint storage used to store operator state locally within the cluster during
execution.
|
static ConfigOption<String> |
StateChangelogOptions.STATE_CHANGE_LOG_STORAGE |
Which storage to use to store state changelog.
|
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<Boolean> |
DeploymentOptions.SUBMIT_FAILED_JOB_ON_APPLICATION_ERROR |
|
static ConfigOption<Boolean> |
MetricOptions.SYSTEM_RESOURCE_METRICS |
Whether Flink should report system resource metrics such as machine's CPU, memory or network
usage.
|
static ConfigOption<Duration> |
MetricOptions.SYSTEM_RESOURCE_METRICS_PROBING_INTERVAL |
Interval between probing of system resource metrics specified in milliseconds.
|
static ConfigOption<String> |
DeploymentOptions.TARGET |
|
static ConfigOption<Duration> |
TaskManagerOptions.TASK_CANCELLATION_INTERVAL |
Time interval in milliseconds between two successive task cancellation attempts.
|
static ConfigOption<Duration> |
TaskManagerOptions.TASK_CANCELLATION_TIMEOUT |
Timeout in milliseconds after which a task cancellation times out and leads to a fatal
TaskManager error.
|
static ConfigOption<Duration> |
TaskManagerOptions.TASK_CANCELLATION_TIMEOUT_TIMERS |
This configures how long we wait for the timers in milliseconds to finish all pending timer
threads when the stream task is cancelled.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.TASK_HEAP_MEMORY |
Task Heap Memory size for TaskExecutors.
|
static ConfigOption<TaskManagerOptions.TaskManagerLoadBalanceMode> |
TaskManagerOptions.TASK_MANAGER_LOAD_BALANCE_MODE |
|
static ConfigOption<String> |
TaskManagerOptions.TASK_MANAGER_LOG_PATH |
|
static ConfigOption<String> |
TaskManagerOptionsInternal.TASK_MANAGER_NODE_ID |
The ID of the node where the TaskManager is located on.
|
static ConfigOption<String> |
ClusterOptions.TASK_MANAGER_PROCESS_WORKING_DIR_BASE |
|
static ConfigOption<Duration> |
ResourceManagerOptions.TASK_MANAGER_REGISTRATION_TIMEOUT |
Timeout for TaskManagers to register at the active resource managers.
|
static ConfigOption<String> |
TaskManagerOptions.TASK_MANAGER_RESOURCE_ID |
The TaskManager's ResourceID.
|
static ConfigOption<String> |
TaskManagerOptionsInternal.TASK_MANAGER_RESOURCE_ID_METADATA |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.TASK_MANAGER_SYSTEM_OUT_LOG_CACHE_SIZE |
|
static ConfigOption<Boolean> |
TaskManagerOptions.TASK_MANAGER_SYSTEM_OUT_LOG_THREAD_NAME |
|
static ConfigOption<TaskManagerOptions.SystemOutMode> |
TaskManagerOptions.TASK_MANAGER_SYSTEM_OUT_MODE |
|
static ConfigOption<Duration> |
ResourceManagerOptions.TASK_MANAGER_TIMEOUT |
The timeout for an idle task manager to be released.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.TASK_OFF_HEAP_MEMORY |
Task Off-Heap Memory size for TaskExecutors.
|
static ConfigOption<Boolean> |
NettyShuffleEnvironmentOptions.TCP_CONNECTION_REUSE_ACROSS_JOBS_ENABLED |
Whether to reuse tcp connections across multi jobs.
|
static ConfigOption<Duration> |
RpcOptions.TCP_TIMEOUT |
The Pekko tcp connection timeout.
|
static ConfigOption<Integer> |
ClusterOptions.THREAD_DUMP_STACKTRACE_MAX_DEPTH |
|
static ConfigOption<Duration> |
WebOptions.TIMEOUT |
Timeout for asynchronous operations by the web monitor 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<Integer> |
CheckpointingOptions.TOLERABLE_FAILURE_NUMBER |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
JobManagerOptions.TOTAL_FLINK_MEMORY |
Total Flink Memory size for the JobManager.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.TOTAL_FLINK_MEMORY |
Total Flink Memory size for the TaskExecutors.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
JobManagerOptions.TOTAL_PROCESS_MEMORY |
Total Process Memory size for the JobManager.
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
TaskManagerOptions.TOTAL_PROCESS_MEMORY |
Total Process Memory size for the TaskExecutors.
|
static ConfigOption<String> |
TraceOptions.TRACE_REPORTERS_LIST |
An optional list of reporter names.
|
static ConfigOption<Integer> |
CheckpointingOptions.UNALIGNED_MAX_SUBTASKS_PER_CHANNEL_STATE_FILE |
|
static ConfigOption<ClusterOptions.UncaughtExceptionHandleMode> |
ClusterOptions.UNCAUGHT_EXCEPTION_HANDLING |
|
static ConfigOption<String> |
WebOptions.UPLOAD_DIR |
The config parameter defining the directory for uploading the job jars.
|
static ConfigOption<String> |
RestOptions.URL_PREFIX |
The url prefix that should be used by clients to construct the full target url.
|
static ConfigOption<Boolean> |
ExecutionOptions.USE_BATCH_STATE_BACKEND |
|
static ConfigOption<Boolean> |
AlgorithmOptions.USE_LARGE_RECORDS_HANDLER |
|
static ConfigOption<PipelineOptions.VertexDescriptionMode> |
PipelineOptions.VERTEX_DESCRIPTION_MODE |
|
static ConfigOption<Boolean> |
PipelineOptions.VERTEX_NAME_INCLUDE_INDEX_PREFIX |
|
static ConfigOption<org.apache.flink.configuration.MemorySize> |
JobEventStoreOptions.WRITE_BUFFER_SIZE |
|
static ConfigOption<String> |
HighAvailabilityOptions.ZOOKEEPER_CLIENT_ACL |
|
static ConfigOption<Map<String,String>> |
HighAvailabilityOptions.ZOOKEEPER_CLIENT_AUTHORIZATION |
|
static ConfigOption<Duration> |
HighAvailabilityOptions.ZOOKEEPER_CONNECTION_TIMEOUT |
|
static ConfigOption<Boolean> |
HighAvailabilityOptions.ZOOKEEPER_ENSEMBLE_TRACKING |
|
static ConfigOption<Duration> |
HighAvailabilityOptions.ZOOKEEPER_MAX_CLOSE_WAIT |
|
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_MAX_RETRY_ATTEMPTS |
|
static ConfigOption<Duration> |
HighAvailabilityOptions.ZOOKEEPER_MAX_RETRY_WAIT |
|
static ConfigOption<Duration> |
HighAvailabilityOptions.ZOOKEEPER_RETRY_WAIT |
|
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<Duration> |
HighAvailabilityOptions.ZOOKEEPER_SESSION_TIMEOUT |
|
static ConfigOption<Integer> |
HighAvailabilityOptions.ZOOKEEPER_SIMULATED_SESSION_EXP_PERCENT |
|
static ConfigOption<Boolean> |
HighAvailabilityOptions.ZOOKEEPER_TOLERATE_SUSPENDED_CONNECTIONS |
|