Constant Field Values

Contents

org.apache.*

  • org.apache.flink.autoscaler.JobAutoScalerImpl<KEY,​Context extends JobAutoScalerContext<KEY>> 
    Modifier and Type Constant Field Value
    protected static final java.lang.String AUTOSCALER_ERROR "AutoscalerError"
  • org.apache.flink.autoscaler.JobVertexScaler<KEY,​Context extends JobAutoScalerContext<KEY>> 
    Modifier and Type Constant Field Value
    protected static final java.lang.String INEFFECTIVE_MESSAGE_FORMAT "Ineffective scaling detected for %s (expected increase: %s, actual increase %s). Blocking of ineffective scaling decisions is %s"
    protected static final java.lang.String INEFFECTIVE_SCALING "IneffectiveScaling"
    protected static final java.lang.String SCALE_LIMITED_MESSAGE_FORMAT "Scaling limited detected for %s (expected parallelism: %s, actual parallelism %s). Scaling limited due to numKeyGroupsOrPartitions : %s\uff0cupperBoundForAlignment(maxParallelism or parallelismUpperLimit): %s, parallelismLowerLimit: %s."
    protected static final java.lang.String SCALING_LIMITED "ScalingLimited"
  • org.apache.flink.autoscaler.ScalingExecutor<KEY,​Context extends JobAutoScalerContext<KEY>> 
    Modifier and Type Constant Field Value
    public static final java.lang.String GC_PRESSURE_MESSAGE "GC Pressure %s is above the allowed limit for scaling operations. Please adjust the available memory manually."
    public static final java.lang.String HEAP_USAGE_MESSAGE "Heap Usage %s is above the allowed limit for scaling operations. Please adjust the available memory manually."
    public static final java.lang.String RESOURCE_QUOTA_REACHED_MESSAGE "Resource usage is above the allowed limit for scaling operations. Please adjust the resource quota manually."
  • org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics 
    Modifier and Type Constant Field Value
    public static final java.lang.String AVERAGE "Average"
    public static final java.lang.String CURRENT "Current"
    public static final java.lang.String JOB_VERTEX_ID "jobVertexID"
  • org.apache.flink.kubernetes.operator.api.utils.SpecUtils 
    Modifier and Type Constant Field Value
    public static final java.lang.String INTERNAL_METADATA_JSON_KEY "resource_metadata"