Class HighAvailabilityOptions


  • public class HighAvailabilityOptions
    extends Object
    The set of configuration options relating to high-availability settings.
    • 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_MAX_RETRY_ATTEMPTS

        public static final ConfigOption<Integer> ZOOKEEPER_MAX_RETRY_ATTEMPTS
      • ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH

        @Deprecated
        public static final ConfigOption<String> ZOOKEEPER_RUNNING_JOB_REGISTRY_PATH
        Deprecated.
        Don't use this option anymore. It has no effect on Flink.
      • ZOOKEEPER_TOLERATE_SUSPENDED_CONNECTIONS

        public static final ConfigOption<Boolean> ZOOKEEPER_TOLERATE_SUSPENDED_CONNECTIONS
      • ZOOKEEPER_ENSEMBLE_TRACKING

        public static final ConfigOption<Boolean> ZOOKEEPER_ENSEMBLE_TRACKING
      • 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.