Package org.apache.flink.autoscaler.config

Class AutoScalerOptions

java.lang.Object

org.apache.flink.autoscaler.config.AutoScalerOptions

public class AutoScalerOptions
extends java.lang.Object

Config options related to the autoscaler module.

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	AUTOSCALER_CONF_PREFIX
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>	AUTOSCALER_ENABLED
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	BACKLOG_PROCESSING_LAG_THRESHOLD
static org.apache.flink.configuration.ConfigOption<MetricAggregator>	BUSY_TIME_AGGREGATOR
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	CATCH_UP_DURATION
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	CPU_QUOTA
static org.apache.flink.configuration.ConfigOption<java.util.List<java.lang.String>>	EXCLUDED_PERIODS
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	FLINK_CLIENT_TIMEOUT
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	GC_PRESSURE_THRESHOLD
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	HEAP_USAGE_THRESHOLD
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	MAX_SCALE_DOWN_FACTOR
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	MAX_SCALE_UP_FACTOR
static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>	MEMORY_QUOTA
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>	MEMORY_SCALING_ENABLED
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>	MEMORY_TUNING_ENABLED
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>	MEMORY_TUNING_MAXIMIZE_MANAGED_MEMORY
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	MEMORY_TUNING_OVERHEAD
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	METRICS_WINDOW
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	OBSERVE_TRUE_PROCESSING_RATE_LAG_THRESHOLD
static org.apache.flink.configuration.ConfigOption<java.lang.Integer>	OBSERVED_TRUE_PROCESSING_RATE_MIN_OBSERVATIONS
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	OBSERVED_TRUE_PROCESSING_RATE_SWITCH_THRESHOLD
static java.lang.String	OLD_K8S_OP_CONF_PREFIX
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>	PREFER_TRACKED_RESTART_TIME
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	RESTART_TIME
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	SCALE_DOWN_INTERVAL
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>	SCALING_EFFECTIVENESS_DETECTION_ENABLED
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	SCALING_EFFECTIVENESS_THRESHOLD
static org.apache.flink.configuration.ConfigOption<java.lang.Boolean>	SCALING_ENABLED
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	SCALING_EVENT_INTERVAL
static org.apache.flink.configuration.ConfigOption<JobVertexScaler.KeyGroupOrPartitionsAdjustMode>	SCALING_KEY_GROUP_PARTITIONS_ADJUST_MODE
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	STABILIZATION_INTERVAL
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	TARGET_UTILIZATION_BOUNDARY	Deprecated.
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	TRACKED_RESTART_TIME_LIMIT
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	UTILIZATION_MAX
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	UTILIZATION_MIN
static org.apache.flink.configuration.ConfigOption<java.lang.Double>	UTILIZATION_TARGET
static org.apache.flink.configuration.ConfigOption<java.util.List<java.lang.String>>	VERTEX_EXCLUDE_IDS
static org.apache.flink.configuration.ConfigOption<java.lang.Integer>	VERTEX_MAX_PARALLELISM
static org.apache.flink.configuration.ConfigOption<java.lang.Integer>	VERTEX_MIN_PARALLELISM
static org.apache.flink.configuration.ConfigOption<java.time.Duration>	VERTEX_SCALING_HISTORY_AGE
static org.apache.flink.configuration.ConfigOption<java.lang.Integer>	VERTEX_SCALING_HISTORY_COUNT

Constructor Summary

Constructors

Constructor	Description
AutoScalerOptions()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

OLD_K8S_OP_CONF_PREFIX

public static final java.lang.String OLD_K8S_OP_CONF_PREFIX

See Also:

Constant Field Values

AUTOSCALER_CONF_PREFIX

public static final java.lang.String AUTOSCALER_CONF_PREFIX

See Also:

Constant Field Values

AUTOSCALER_ENABLED

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

SCALING_ENABLED

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

METRICS_WINDOW

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

STABILIZATION_INTERVAL

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

EXCLUDED_PERIODS

public static final org.apache.flink.configuration.ConfigOption<java.util.List<java.lang.String>> EXCLUDED_PERIODS

UTILIZATION_TARGET

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

TARGET_UTILIZATION_BOUNDARY

@Deprecated
public static final org.apache.flink.configuration.ConfigOption<java.lang.Double> TARGET_UTILIZATION_BOUNDARY

Deprecated.

UTILIZATION_MAX

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

UTILIZATION_MIN

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

SCALE_DOWN_INTERVAL

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

VERTEX_MIN_PARALLELISM

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

VERTEX_MAX_PARALLELISM

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

MAX_SCALE_DOWN_FACTOR

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

MAX_SCALE_UP_FACTOR

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

CATCH_UP_DURATION

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

RESTART_TIME

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

PREFER_TRACKED_RESTART_TIME

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

TRACKED_RESTART_TIME_LIMIT

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

BACKLOG_PROCESSING_LAG_THRESHOLD

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

OBSERVE_TRUE_PROCESSING_RATE_LAG_THRESHOLD

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

OBSERVED_TRUE_PROCESSING_RATE_SWITCH_THRESHOLD

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

OBSERVED_TRUE_PROCESSING_RATE_MIN_OBSERVATIONS

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

SCALING_EFFECTIVENESS_DETECTION_ENABLED

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

SCALING_EFFECTIVENESS_THRESHOLD

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

GC_PRESSURE_THRESHOLD

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

HEAP_USAGE_THRESHOLD

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

MEMORY_TUNING_ENABLED

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

MEMORY_SCALING_ENABLED

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

MEMORY_TUNING_OVERHEAD

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

MEMORY_TUNING_MAXIMIZE_MANAGED_MEMORY

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

VERTEX_SCALING_HISTORY_COUNT

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

VERTEX_SCALING_HISTORY_AGE

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

BUSY_TIME_AGGREGATOR

public static final org.apache.flink.configuration.ConfigOption<MetricAggregator> BUSY_TIME_AGGREGATOR

VERTEX_EXCLUDE_IDS

public static final org.apache.flink.configuration.ConfigOption<java.util.List<java.lang.String>> VERTEX_EXCLUDE_IDS

SCALING_EVENT_INTERVAL

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

FLINK_CLIENT_TIMEOUT

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

MEMORY_QUOTA

public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> MEMORY_QUOTA

CPU_QUOTA

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

SCALING_KEY_GROUP_PARTITIONS_ADJUST_MODE

public static final org.apache.flink.configuration.ConfigOption<JobVertexScaler.KeyGroupOrPartitionsAdjustMode> SCALING_KEY_GROUP_PARTITIONS_ADJUST_MODE

Constructor Detail

AutoScalerOptions

public AutoScalerOptions()