Constant Field Values

Contents

• org.apache.*

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_REQUEST_SLOW_GROUP	"Slow"
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"