org.apache.flink.configuration

Class HighAvailabilityOptions

java.lang.Object

org.apache.flink.configuration.HighAvailabilityOptions

@PublicEvolving
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 and Mesos.
static ConfigOption<String>	HA_JOB_DELAY The time before a JobManager after a fail over recovers the current jobs.
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_CHECKPOINT_COUNTER_PATH ZooKeeper root path (ZNode) for checkpoint counters.
static ConfigOption<String>	HA_ZOOKEEPER_CHECKPOINTS_PATH ZooKeeper root path (ZNode) for completed checkpoints.
static ConfigOption<String>	HA_ZOOKEEPER_JOBGRAPHS_PATH ZooKeeper root path (ZNode) for job graphs.
static ConfigOption<String>	HA_ZOOKEEPER_LATCH_PATH
static ConfigOption<String>	HA_ZOOKEEPER_LEADER_PATH
static ConfigOption<String>	HA_ZOOKEEPER_MESOS_WORKERS_PATH ZooKeeper root path (ZNode) for Mesos workers.
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

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". Can also be set to FQN of 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 and Mesos.

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_JOB_DELAY

public static final ConfigOption<String> HA_JOB_DELAY

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

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_LATCH_PATH

public static final ConfigOption<String> HA_ZOOKEEPER_LATCH_PATH

HA_ZOOKEEPER_JOBGRAPHS_PATH

public static final ConfigOption<String> HA_ZOOKEEPER_JOBGRAPHS_PATH

ZooKeeper root path (ZNode) for job graphs.

HA_ZOOKEEPER_LEADER_PATH

public static final ConfigOption<String> HA_ZOOKEEPER_LEADER_PATH

HA_ZOOKEEPER_CHECKPOINTS_PATH

public static final ConfigOption<String> HA_ZOOKEEPER_CHECKPOINTS_PATH

ZooKeeper root path (ZNode) for completed checkpoints.

HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH

public static final ConfigOption<String> HA_ZOOKEEPER_CHECKPOINT_COUNTER_PATH

ZooKeeper root path (ZNode) for checkpoint counters.

HA_ZOOKEEPER_MESOS_WORKERS_PATH

@PublicEvolving
public static final ConfigOption<String> HA_ZOOKEEPER_MESOS_WORKERS_PATH

ZooKeeper root path (ZNode) for Mesos workers.

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