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

      • VERSION_CONF_PREFIX

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

      • NAMESPACE_CONF_PREFIX

        public static final java.lang.String NAMESPACE_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_CHECKPOINT_TRIGGER_GRACE_PERIOD

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_CHECKPOINT_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

      • JOB_UPGRADE_INPLACE_SCALING_ENABLED

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

      • 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_CLEANUP_ENABLED

        public static final org.apache.flink.configuration.ConfigOption<java.lang.Boolean> OPERATOR_SAVEPOINT_CLEANUP_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_EXCEPTION_LABEL_MAPPER

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

      • 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.lang.String> PERIODIC_SAVEPOINT_INTERVAL

      • PERIODIC_CHECKPOINT_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.lang.String> PERIODIC_CHECKPOINT_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_MAX_INTERVAL

        public static final org.apache.flink.configuration.ConfigOption<java.time.Duration> OPERATOR_RETRY_MAX_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_RATE_LIMITER_PERIOD

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

      • OPERATOR_RATE_LIMITER_LIMIT

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

      • 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_JOB_UPGRADE_LAST_STATE_CHECKPOINT_MAX_AGE

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

      • OPERATOR_SAVEPOINT_FORMAT_TYPE

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

      • OPERATOR_CHECKPOINT_TYPE

        public static final org.apache.flink.configuration.ConfigOption<CheckpointType> OPERATOR_CHECKPOINT_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_TERMINATION_TIMEOUT

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

      • 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_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_ENABLED

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

      • OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_WINDOW

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

      • 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

      • CANARY_RESOURCE_TIMEOUT

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

      • OPERATOR_JM_STARTUP_PROBE_ENABLED

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

      • POD_TEMPLATE_MERGE_BY_NAME

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

      • RESOURCE_DELETION_PROPAGATION

        public static final org.apache.flink.configuration.ConfigOption<io.fabric8.kubernetes.api.model.DeletionPropagation> RESOURCE_DELETION_PROPAGATION

      • SAVEPOINT_ON_DELETION

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

      • DRAIN_ON_SAVEPOINT_DELETION

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

      • REFRESH_CLUSTER_RESOURCE_VIEW

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

    • 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)