org.apache.flink.configuration

Class HighAvailabilityOptions

java.lang.Object

org.apache.flink.configuration.HighAvailabilityOptions

public class HighAvailabilityOptions
extends Object

The set of configuration options relating to high-availability settings.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<String>	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>	HA_JOB_DELAY Deprecated. Don't use this option anymore. It has no effect on Flink.
static ConfigOption<String>	HA_JOB_MANAGER_PORT_RANGE Optional port (range) used by the job manager in high-availability mode.
static ConfigOption<String>	HA_MODE Defines high-availability mode used for the cluster execution.
static ConfigOption<String>	HA_STORAGE_PATH File system path (URI) where Flink persists metadata in high-availability setups.
static ConfigOption<String>	HA_ZOOKEEPER_JOBGRAPHS_PATH ZooKeeper root path (ZNode) for job graphs.
static ConfigOption<String>	HA_ZOOKEEPER_QUORUM The ZooKeeper quorum to use, when running Flink in a high-availability mode with ZooKeeper.
static ConfigOption<String>	HA_ZOOKEEPER_ROOT The root path under which Flink stores its entries in ZooKeeper.
static ConfigOption<String>	ZOOKEEPER_CLIENT_ACL
static ConfigOption<Integer>	ZOOKEEPER_CONNECTION_TIMEOUT
static ConfigOption<Integer>	ZOOKEEPER_MAX_RETRY_ATTEMPTS
static ConfigOption<Integer>	ZOOKEEPER_RETRY_WAIT
static ConfigOption<String>	ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH
static ConfigOption<Integer>	ZOOKEEPER_SESSION_TIMEOUT
static ConfigOption<Boolean>	ZOOKEEPER_TOLERATE_SUSPENDED_CONNECTIONS

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

HA_MODE

public static final ConfigOption<String> HA_MODE

Defines high-availability mode used for the cluster execution. A value of "NONE" signals no highly available setup. To enable high-availability, set this mode to "ZOOKEEPER" or "KUBERNETES". Can also be set to the FQN of the HighAvailability factory class.

HA_CLUSTER_ID

public static final ConfigOption<String> 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.

HA_STORAGE_PATH

public static final ConfigOption<String> HA_STORAGE_PATH

File system path (URI) where Flink persists metadata in high-availability setups.

HA_JOB_MANAGER_PORT_RANGE

public static final ConfigOption<String> HA_JOB_MANAGER_PORT_RANGE

Optional port (range) used by the job manager in high-availability mode.

HA_ZOOKEEPER_QUORUM

public static final ConfigOption<String> HA_ZOOKEEPER_QUORUM

The ZooKeeper quorum to use, when running Flink in a high-availability mode with ZooKeeper.

HA_ZOOKEEPER_ROOT

public static final ConfigOption<String> HA_ZOOKEEPER_ROOT

The root path under which Flink stores its entries in ZooKeeper.

HA_ZOOKEEPER_JOBGRAPHS_PATH

public static final ConfigOption<String> HA_ZOOKEEPER_JOBGRAPHS_PATH

ZooKeeper root path (ZNode) for job graphs.

ZOOKEEPER_SESSION_TIMEOUT

public static final ConfigOption<Integer> ZOOKEEPER_SESSION_TIMEOUT

ZOOKEEPER_CONNECTION_TIMEOUT

public static final ConfigOption<Integer> ZOOKEEPER_CONNECTION_TIMEOUT

ZOOKEEPER_RETRY_WAIT

public static final ConfigOption<Integer> ZOOKEEPER_RETRY_WAIT

ZOOKEEPER_MAX_RETRY_ATTEMPTS

public static final ConfigOption<Integer> ZOOKEEPER_MAX_RETRY_ATTEMPTS

ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH

public static final ConfigOption<String> ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH

ZOOKEEPER_CLIENT_ACL

public static final ConfigOption<String> ZOOKEEPER_CLIENT_ACL

ZOOKEEPER_TOLERATE_SUSPENDED_CONNECTIONS

public static final ConfigOption<Boolean> ZOOKEEPER_TOLERATE_SUSPENDED_CONNECTIONS

HA_JOB_DELAY

@Deprecated
public static final ConfigOption<String> HA_JOB_DELAY

Deprecated. Don't use this option anymore. It has no effect on Flink.

The time before a JobManager after a fail over recovers the current jobs.