Package org.apache.flink.kubernetes.operator.config

Class KubernetesOperatorConfigOptions

  • public class KubernetesOperatorConfigOptions
extends java.lang.Object
    This class holds configuration constants used by flink operator.

    • Field Detail

      • K8S_OP_CONF_PREFIX

        public static final java.lang.String K8S_OP_CONF_PREFIX
        See Also:
        Constant Field Values

      • SECTION_ADVANCED

        public static final java.lang.String SECTION_ADVANCED
        See Also:
        Constant Field Values

      • OPERATOR_RECONCILE_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_RECONCILE_INTERVAL

      • OPERATOR_OBSERVER_REST_READY_DELAY

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_OBSERVER_REST_READY_DELAY

      • OPERATOR_RECONCILE_PARALLELISM

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_RECONCILE_PARALLELISM

      • OPERATOR_OBSERVER_PROGRESS_CHECK_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_OBSERVER_PROGRESS_CHECK_INTERVAL

      • OPERATOR_SAVEPOINT_TRIGGER_GRACE_PERIOD

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_SAVEPOINT_TRIGGER_GRACE_PERIOD

      • OPERATOR_FLINK_CLIENT_TIMEOUT

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_FLINK_CLIENT_TIMEOUT

      • OPERATOR_FLINK_CLIENT_CANCEL_TIMEOUT

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_FLINK_CLIENT_CANCEL_TIMEOUT

      • OPERATOR_RESOURCE_CLEANUP_TIMEOUT

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_RESOURCE_CLEANUP_TIMEOUT

      • DEPLOYMENT_ROLLBACK_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> DEPLOYMENT_ROLLBACK_ENABLED

      • DEPLOYMENT_READINESS_TIMEOUT

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> DEPLOYMENT_READINESS_TIMEOUT

      • OPERATOR_USER_ARTIFACTS_BASE_DIR

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> OPERATOR_USER_ARTIFACTS_BASE_DIR

      • JOB_UPGRADE_IGNORE_PENDING_SAVEPOINT

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> JOB_UPGRADE_IGNORE_PENDING_SAVEPOINT

      • OPERATOR_DYNAMIC_CONFIG_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_DYNAMIC_CONFIG_ENABLED

      • OPERATOR_DYNAMIC_CONFIG_CHECK_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_DYNAMIC_CONFIG_CHECK_INTERVAL

      • OPERATOR_CONFIG_CACHE_TIMEOUT

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_CONFIG_CACHE_TIMEOUT

      • OPERATOR_CONFIG_CACHE_SIZE

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_CONFIG_CACHE_SIZE

      • OPERATOR_JM_DEPLOYMENT_RECOVERY_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_JM_DEPLOYMENT_RECOVERY_ENABLED

      • OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT

      • OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT_THRESHOLD

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT_THRESHOLD

      • OPERATOR_SAVEPOINT_HISTORY_MAX_AGE

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_SAVEPOINT_HISTORY_MAX_AGE

      • OPERATOR_EXCEPTION_STACK_TRACE_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_EXCEPTION_STACK_TRACE_ENABLED

      • OPERATOR_EXCEPTION_STACK_TRACE_MAX_LENGTH

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_EXCEPTION_STACK_TRACE_MAX_LENGTH

      • OPERATOR_EXCEPTION_FIELD_MAX_LENGTH

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_EXCEPTION_FIELD_MAX_LENGTH

      • OPERATOR_EXCEPTION_THROWABLE_LIST_MAX_COUNT

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_EXCEPTION_THROWABLE_LIST_MAX_COUNT

      • OPERATOR_SAVEPOINT_HISTORY_MAX_AGE_THRESHOLD

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_SAVEPOINT_HISTORY_MAX_AGE_THRESHOLD

      • JAR_ARTIFACT_HTTP_HEADER

        public static final org.apache.flink.configuration.ConfigOption<java.util.Map<java.lang.String,​java.lang.String>> JAR_ARTIFACT_HTTP_HEADER

      • PERIODIC_SAVEPOINT_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> PERIODIC_SAVEPOINT_INTERVAL

      • OPERATOR_WATCHED_NAMESPACES

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> OPERATOR_WATCHED_NAMESPACES

      • OPERATOR_LABEL_SELECTOR

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> OPERATOR_LABEL_SELECTOR

      • OPERATOR_DYNAMIC_NAMESPACES_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_DYNAMIC_NAMESPACES_ENABLED

      • OPERATOR_RETRY_INITIAL_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_RETRY_INITIAL_INTERVAL

      • OPERATOR_RETRY_INTERVAL_MULTIPLIER

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Double> OPERATOR_RETRY_INTERVAL_MULTIPLIER

      • OPERATOR_RETRY_MAX_ATTEMPTS

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_RETRY_MAX_ATTEMPTS

      • OPERATOR_JOB_UPGRADE_LAST_STATE_FALLBACK_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_JOB_UPGRADE_LAST_STATE_FALLBACK_ENABLED

      • OPERATOR_SAVEPOINT_FORMAT_TYPE

        public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.core.execution.SavepointFormatType> OPERATOR_SAVEPOINT_FORMAT_TYPE

      • OPERATOR_HEALTH_PROBE_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_HEALTH_PROBE_ENABLED

      • OPERATOR_HEALTH_PROBE_PORT

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_HEALTH_PROBE_PORT

      • OPERATOR_STOP_ON_INFORMER_ERROR

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_STOP_ON_INFORMER_ERROR

      • OPERATOR_CLUSTER_HEALTH_CHECK_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_CLUSTER_HEALTH_CHECK_ENABLED

      • OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_WINDOW

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_WINDOW

      • OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_THRESHOLD

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Integer> OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_THRESHOLD

      • OPERATOR_JOB_RESTART_FAILED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_JOB_RESTART_FAILED

      • OPERATOR_LEADER_ELECTION_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_LEADER_ELECTION_ENABLED

      • OPERATOR_LEADER_ELECTION_LEASE_NAME

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> OPERATOR_LEADER_ELECTION_LEASE_NAME

      • OPERATOR_LEADER_ELECTION_LEASE_DURATION

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_LEADER_ELECTION_LEASE_DURATION

      • OPERATOR_LEADER_ELECTION_RENEW_DEADLINE

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_LEADER_ELECTION_RENEW_DEADLINE

      • OPERATOR_LEADER_ELECTION_RETRY_PERIOD

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_LEADER_ELECTION_RETRY_PERIOD

      • OPERATOR_JM_SHUTDOWN_TTL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_JM_SHUTDOWN_TTL

    • Constructor Detail

      • KubernetesOperatorConfigOptions

        public KubernetesOperatorConfigOptions()

    • Method Detail

      • operatorConfig

        public static org.apache.flink.configuration.ConfigOptions.OptionBuilder operatorConfig​(java.lang.String key)

      • operatorConfigKey

        public static java.lang.String operatorConfigKey​(java.lang.String key)