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.config.AutoScalerOptions Modifier and Type Constant Field Value public static final java.lang.String
AUTOSCALER_CONF_PREFIX
"job.autoscaler."
public static final java.lang.String
OLD_K8S_OP_CONF_PREFIX
"kubernetes.operator."
-
org.apache.flink.autoscaler.event.AutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>> Modifier and Type Constant Field Value public static final java.lang.String
SCALING_EXECUTION_DISABLED_REASON
"%s:%s, recommended parallelism change:"
public static final java.lang.String
SCALING_REPORT_KEY
"ScalingExecutor"
public static final java.lang.String
SCALING_REPORT_REASON
"ScalingReport"
public static final java.lang.String
SCALING_SUMMARY_ENTRY
"{ Vertex ID %s | Parallelism %d -> %d | Processing capacity %.2f -> %.2f | Target data rate %.2f}"
public static final java.lang.String
SCALING_SUMMARY_HEADER_SCALING_EXECUTION_DISABLED
"Scaling execution disabled by config "
public static final java.lang.String
SCALING_SUMMARY_HEADER_SCALING_EXECUTION_ENABLED
"Scaling execution enabled, begin scaling vertices:"
-
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.autoscaler.standalone.StandaloneAutoscalerExecutor<KEY,Context extends JobAutoScalerContext<KEY>> Modifier and Type Constant Field Value protected static final java.lang.String
AUTOSCALER_ERROR
"AutoscalerError"
-
org.apache.flink.kubernetes.operator.admission.AdmissionHandler Modifier and Type Constant Field Value protected static final java.lang.String
MUTATOR_REQUEST_PATH
"/mutate"
protected static final java.lang.String
VALIDATE_REQUEST_PATH
"/validate"
-
org.apache.flink.kubernetes.operator.api.CrdConstants Modifier and Type Constant Field Value public static final java.lang.String
API_GROUP
"flink.apache.org"
public static final java.lang.String
API_VERSION
"v1beta1"
public static final java.lang.String
EPHEMERAL_STORAGE
"ephemeral-storage"
public static final java.lang.String
KIND_FLINK_DEPLOYMENT
"FlinkDeployment"
public static final java.lang.String
KIND_FLINK_STATE_SNAPSHOT
"FlinkStateSnapshot"
public static final java.lang.String
KIND_SESSION_JOB
"FlinkSessionJob"
public static final java.lang.String
LABEL_SNAPSHOT_JOB_REFERENCE_KIND
"job-reference.kind"
public static final java.lang.String
LABEL_SNAPSHOT_JOB_REFERENCE_NAME
"job-reference.name"
public static final java.lang.String
LABEL_SNAPSHOT_STATE
"snapshot.state"
public static final java.lang.String
LABEL_SNAPSHOT_TRIGGER_TYPE
"snapshot.trigger-type"
public static final java.lang.String
LABEL_SNAPSHOT_TYPE
"snapshot.type"
public static final java.lang.String
LABEL_TARGET_SESSION
"target.session"
-
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"
-
org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler Modifier and Type Constant Field Value public static final java.lang.String
PARALLELISM_MAP_KEY
"parallelismMap"
-
org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore Modifier and Type Constant Field Value protected static final java.lang.String
COLLECTED_METRICS_KEY
"collectedMetrics"
protected static final java.lang.String
CONFIG_OVERRIDES_KEY
"configOverrides"
protected static final java.lang.String
DELAYED_SCALE_DOWN
"delayedScaleDown"
protected static final int
MAX_CM_BYTES
1000000
protected static final java.lang.String
PARALLELISM_OVERRIDES_KEY
"parallelismOverrides"
protected static final java.lang.String
SCALING_HISTORY_KEY
"scalingHistory"
protected static final java.lang.String
SCALING_TRACKING_KEY
"scalingTracking"
-
org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder Modifier and Type Constant Field Value protected static final java.lang.String
GENERATED_FILE_PREFIX
"flink_op_generated_"
-
org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions Modifier and Type Constant Field Value public static final java.lang.String
K8S_OP_CONF_PREFIX
"kubernetes.operator."
public static final java.lang.String
NAMESPACE_CONF_PREFIX
"kubernetes.operator.default-configuration.namespace."
public static final java.lang.String
SECTION_ADVANCED
"system_advanced"
public static final java.lang.String
SECTION_DYNAMIC
"dynamic"
public static final java.lang.String
SECTION_SYSTEM
"system"
public static final java.lang.String
VERSION_CONF_PREFIX
"kubernetes.operator.default-configuration.flink-version."
-
org.apache.flink.kubernetes.operator.exception.DeploymentFailedException Modifier and Type Constant Field Value public static final java.lang.String
REASON_CRASH_LOOP_BACKOFF
"CrashLoopBackOff"
public static final java.lang.String
REASON_ERR_IMAGE_PULL
"ErrImagePull"
public static final java.lang.String
REASON_IMAGE_PULL_BACKOFF
"ImagePullBackOff"
-
org.apache.flink.kubernetes.operator.health.CanaryResourceManager<CR extends AbstractFlinkResource<?,?>> Modifier and Type Constant Field Value public static final java.lang.String
CANARY_LABEL
"flink.apache.org/canary"
-
org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator Modifier and Type Constant Field Value public static final java.lang.String
APPLICATION_MODE_ARG
"standalone-job"
public static final java.lang.String
JOBMANAGER_ENTRYPOINT_ARG
"jobmanager"
-
org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator Modifier and Type Constant Field Value public static final java.lang.String
TASKMANAGER_ENTRYPOINT_ARG
"taskmanager"
-
org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics Modifier and Type Constant Field Value public static final java.lang.String
COUNTER_NAME
"Count"
public static final java.lang.String
CPU_NAME
"Cpu"
public static final java.lang.String
FLINK_MINOR_VERSION_GROUP_NAME
"FlinkMinorVersion"
public static final java.lang.String
FLINK_VERSION_GROUP_NAME
"FlinkVersion"
public static final java.lang.String
MALFORMED_MINOR_VERSION
"MALFORMED"
public static final java.lang.String
MEMORY_NAME
"Memory"
public static final java.lang.String
RESOURCE_USAGE_GROUP_NAME
"ResourceUsage"
public static final java.lang.String
STATUS_GROUP_NAME
"JmDeploymentStatus"
public static final java.lang.String
UNKNOWN_VERSION
"UNKNOWN"
-
org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics Modifier and Type Constant Field Value public static final java.lang.String
COUNTER_NAME
"Count"
-
org.apache.flink.kubernetes.operator.metrics.FlinkStateSnapshotMetrics Modifier and Type Constant Field Value public static final java.lang.String
CHECKPOINT_GROUP_NAME
"Checkpoint"
public static final java.lang.String
COUNTER_GROUP_NAME
"Count"
public static final java.lang.String
SAVEPOINT_GROUP_NAME
"Savepoint"
public static final java.lang.String
STATE_GROUP_NAME
"State"
-
org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics Modifier and Type Constant Field Value public static final java.lang.String
COUNTER
"Count"
public static final java.lang.String
HISTO
"TimeNanos"
public static final java.lang.String
HTTP_REQUEST_FAILED_GROUP
"Failed"
public static final java.lang.String
HTTP_REQUEST_GROUP
"HttpRequest"
public static final java.lang.String
HTTP_RESPONSE_1XX
"1xx"
public static final java.lang.String
HTTP_RESPONSE_2XX
"2xx"
public static final java.lang.String
HTTP_RESPONSE_3XX
"3xx"
public static final java.lang.String
HTTP_RESPONSE_4XX
"4xx"
public static final java.lang.String
HTTP_RESPONSE_5XX
"5xx"
public static final java.lang.String
HTTP_RESPONSE_GROUP
"HttpResponse"
public static final java.lang.String
KUBE_CLIENT_GROUP
"KubeClient"
public static final java.lang.String
METER
"NumPerSecond"
public static final java.lang.String
REQUEST_START_TIME_HEADER
"requestStartTimeNanos"
-
org.apache.flink.kubernetes.operator.observer.JobStatusObserver<R extends AbstractFlinkResource<?,?>> Modifier and Type Constant Field Value public static final java.lang.String
JOB_NOT_FOUND_ERR
"Job Not Found"
-
org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> Modifier and Type Constant Field Value public static final java.lang.String
MSG_ROLLBACK
"Rolling back failed deployment."
public static final java.lang.String
MSG_SPEC_CHANGED
"%s change(s) detected (%s), starting reconciliation."
public static final java.lang.String
MSG_SUBMIT
"Starting deployment"
public static final java.lang.String
MSG_SUSPENDED
"Suspending existing deployment."
-
org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> Modifier and Type Constant Field Value public static final java.lang.String
LAST_STATE_DUMMY_SP_PATH
"KUBERNETES_OPERATOR_LAST_STATE"
-
org.apache.flink.kubernetes.operator.service.AbstractFlinkService Modifier and Type Constant Field Value public static final java.lang.String
FIELD_NAME_TOTAL_CPU
"total-cpu"
public static final java.lang.String
FIELD_NAME_TOTAL_MEMORY
"total-memory"
-
org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders Modifier and Type Constant Field Value public static final java.lang.String
URL
"/jobs/:jobid/checkpoints"
-
org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration Modifier and Type Constant Field Value public static final java.lang.String
FIELD_NAME_FLINK_REVISION
"flink-revision"
public static final java.lang.String
FIELD_NAME_FLINK_VERSION
"flink-version"
-
org.apache.flink.kubernetes.operator.utils.EnvUtils Modifier and Type Constant Field Value public static final java.lang.String
ENV_CONF_OVERRIDE_DIR
"CONF_OVERRIDE_DIR"
public static final java.lang.String
ENV_HOSTNAME
"HOSTNAME"
public static final java.lang.String
ENV_KUBERNETES_SERVICE_HOST
"KUBERNETES_SERVICE_HOST"
public static final java.lang.String
ENV_OPERATOR_KEYSTORE_PASSWORD
"OPERATOR_KEYSTORE_PASSWORD"
public static final java.lang.String
ENV_OPERATOR_KEYSTORE_PATH
"OPERATOR_KEYSTORE_PATH"
public static final java.lang.String
ENV_OPERATOR_NAME
"OPERATOR_NAME"
public static final java.lang.String
ENV_OPERATOR_NAMESPACE
"OPERATOR_NAMESPACE"
public static final java.lang.String
ENV_OPERATOR_TRUSTSTORE_PATH
"OPERATOR_TRUSTSTORE_PATH"
public static final java.lang.String
ENV_WATCH_NAMESPACES
"WATCH_NAMESPACES"
public static final java.lang.String
ENV_WEBHOOK_KEYSTORE_FILE
"WEBHOOK_KEYSTORE_FILE"
public static final java.lang.String
ENV_WEBHOOK_KEYSTORE_PASSWORD
"WEBHOOK_KEYSTORE_PASSWORD"
public static final java.lang.String
ENV_WEBHOOK_KEYSTORE_TYPE
"WEBHOOK_KEYSTORE_TYPE"
public static final java.lang.String
ENV_WEBHOOK_SERVER_PORT
"WEBHOOK_SERVER_PORT"
-
org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils Modifier and Type Constant Field Value public static final java.lang.String
LABELS
"labels"
-
org.apache.flink.kubernetes.operator.utils.FlinkUtils Modifier and Type Constant Field Value public static final java.lang.String
CR_GENERATION_LABEL
"flinkdeployment.flink.apache.org/generation"
-
org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils Modifier and Type Constant Field Value public static final java.lang.String
LABEL_TYPE_STANDALONE_TYPE
"flink-standalone-kubernetes"
-
org.apache.flink.runtime.rest.messages.job.JobDetailsInfo Modifier and Type Constant Field Value public static final java.lang.String
FIELD_NAME_DURATION
"duration"
public static final java.lang.String
FIELD_NAME_END_TIME
"end-time"
public static final java.lang.String
FIELD_NAME_IS_STOPPABLE
"isStoppable"
public static final java.lang.String
FIELD_NAME_JOB_ID
"jid"
public static final java.lang.String
FIELD_NAME_JOB_NAME
"name"
public static final java.lang.String
FIELD_NAME_JOB_STATUS
"state"
public static final java.lang.String
FIELD_NAME_JOB_VERTEX_INFOS
"vertices"
public static final java.lang.String
FIELD_NAME_JOB_VERTICES_PER_STATE
"status-counts"
public static final java.lang.String
FIELD_NAME_JSON_PLAN
"plan"
public static final java.lang.String
FIELD_NAME_MAX_PARALLELISM
"maxParallelism"
public static final java.lang.String
FIELD_NAME_NOW
"now"
public static final java.lang.String
FIELD_NAME_START_TIME
"start-time"
public static final java.lang.String
FIELD_NAME_TIMESTAMPS
"timestamps"
-
org.apache.flink.runtime.rest.messages.job.JobDetailsInfo.JobVertexDetailsInfo Modifier and Type Constant Field Value public static final java.lang.String
FIELD_NAME_JOB_VERTEX_DURATION
"duration"
public static final java.lang.String
FIELD_NAME_JOB_VERTEX_END_TIME
"end-time"
public static final java.lang.String
FIELD_NAME_JOB_VERTEX_ID
"id"
public static final java.lang.String
FIELD_NAME_JOB_VERTEX_METRICS
"metrics"
public static final java.lang.String
FIELD_NAME_JOB_VERTEX_NAME
"name"
public static final java.lang.String
FIELD_NAME_JOB_VERTEX_START_TIME
"start-time"
public static final java.lang.String
FIELD_NAME_JOB_VERTEX_STATE
"status"
public static final java.lang.String
FIELD_NAME_MAX_PARALLELISM
"maxParallelism"
public static final java.lang.String
FIELD_NAME_PARALLELISM
"parallelism"
public static final java.lang.String
FIELD_NAME_SLOT_SHARING_GROUP_ID
"slotSharingGroupId"
public static final java.lang.String
FIELD_NAME_TASKS_PER_STATE
"tasks"
-
org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo Modifier and Type Constant Field Value public static final java.lang.String
FIELD_NAME_ACC_BACK_PRESSURE
"accumulated-backpressured-time"
public static final java.lang.String
FIELD_NAME_ACC_BUSY
"accumulated-busy-time"
public static final java.lang.String
FIELD_NAME_ACC_IDLE
"accumulated-idle-time"
public static final java.lang.String
FIELD_NAME_BYTES_READ
"read-bytes"
public static final java.lang.String
FIELD_NAME_BYTES_WRITTEN
"write-bytes"
public static final java.lang.String
FIELD_NAME_RECORDS_READ
"read-records"
public static final java.lang.String
FIELD_NAME_RECORDS_WRITTEN
"write-records"