Modifier and Type | Field and Description |
---|---|
static ConfigOption<Double> |
TaskManagerOptions.CPU_CORES
This config option describes number of cpu cores of task executors.
|
static ConfigOption<Boolean> |
AkkaOptions.FORCE_RPC_INVOCATION_SERIALIZATION |
static ConfigOption<Long> |
NettyShuffleEnvironmentOptions.NETWORK_EXCLUSIVE_BUFFERS_REQUEST_TIMEOUT_MILLISECONDS
The timeout for requesting exclusive buffers for each channel.
|
static ConfigOption<Boolean> |
JobManagerOptions.PARTITION_RELEASE_DURING_JOB_EXECUTION
Config parameter controlling whether partitions should already be released during the job
execution.
|
static ConfigOption<List<String>> |
CoreOptions.PLUGIN_ALWAYS_PARENT_FIRST_LOADER_PATTERNS
Plugin-specific option of
CoreOptions.ALWAYS_PARENT_FIRST_LOADER_PATTERNS . |
static ConfigOption<List<String>> |
CoreOptions.PLUGIN_ALWAYS_PARENT_FIRST_LOADER_PATTERNS_ADDITIONAL |
static ConfigOption<java.time.Duration> |
ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY |
static ConfigOption<Boolean> |
ExecutionOptions.SORT_INPUTS |
static ConfigOption<MemorySize> |
ExecutionOptions.SORTED_INPUTS_MEMORY |
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_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<String> |
CheckpointingOptions.STATE_BACKEND
Deprecated.
|
static ConfigOption<Boolean> |
ExecutionOptions.USE_BATCH_STATE_BACKEND |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<String> |
KubernetesConfigOptions.KUBERNETES_NODE_NAME_LABEL
This will only be used to support blocklist mechanism, which is experimental currently, so we
do not want to expose this option in the documentation.
|
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Map<String,String>> |
PythonOptions.PYTHON_ARCHIVES_DISTRIBUTED_CACHE_INFO |
static ConfigOption<Map<String,String>> |
PythonOptions.PYTHON_FILES_DISTRIBUTED_CACHE_INFO |
static ConfigOption<Map<String,String>> |
PythonOptions.PYTHON_JOB_OPTIONS |
static ConfigOption<String> |
PythonOptions.PYTHON_LOOPBACK_SERVER_ADDRESS |
static ConfigOption<Map<String,String>> |
PythonOptions.PYTHON_REQUIREMENTS_FILE_DISTRIBUTED_CACHE_INFO |
Modifier and Type | Class and Description |
---|---|
class |
ClientCoordinationHeaders
Message headers for the
ClientCoordinationHandler . |
Modifier and Type | Class and Description |
---|---|
class |
JarPlanGetHeaders
Message headers for
JarPlanHandler . |
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Integer> |
TableConfigOptions.MAX_MEMBERS_GENERATED_CODE |
static ConfigOption<MemorySize> |
ExecutionConfigOptions.TABLE_EXEC_RESOURCE_EXTERNAL_BUFFER_MEMORY |
static ConfigOption<MemorySize> |
ExecutionConfigOptions.TABLE_EXEC_RESOURCE_HASH_AGG_MEMORY |
static ConfigOption<MemorySize> |
ExecutionConfigOptions.TABLE_EXEC_RESOURCE_HASH_JOIN_MEMORY |
static ConfigOption<MemorySize> |
ExecutionConfigOptions.TABLE_EXEC_RESOURCE_SORT_MEMORY |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.