Constant Field Values

Contents

• org.apache.*

org.apache.*

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_SESSION_JOB	"FlinkSessionJob"
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.AutoScalerInfo

Modifier and Type	Constant Field	Value
protected static final java.lang.String	COLLECTED_METRICS_KEY	"collectedMetrics"
protected static final int	MAX_CM_BYTES	1000000
protected static final java.lang.String	SCALING_HISTORY_KEY	"scalingHistory"

org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler

Modifier and Type	Constant Field	Value
public static final java.lang.String	INNEFFECTIVE_MESSAGE_FORMAT	"Skipping further scale up after ineffective previous scale up for %s"

org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

Modifier and Type	Constant Field	Value
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_DISABLED	"Recommended parallelism change:"
public static final java.lang.String	SCALING_SUMMARY_HEADER_SCALING_ENABLED	"Scaling vertices:"

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	SECTION_ADVANCED	"system_advanced"
public static final java.lang.String	SECTION_DYNAMIC	"dynamic"
public static final java.lang.String	SECTION_SYSTEM	"system"

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_VERSION_GROUP_NAME	"FlinkVersion"
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"

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.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"

org.apache.flink.kubernetes.operator.observer.JobStatusObserver<R extends AbstractFlinkResource<?,?>>

Modifier and Type	Constant Field	Value
public static final java.lang.String	MISSING_SESSION_JOB_ERR	"Missing Session Job"

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.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_NAME	"OPERATOR_NAME"
public static final java.lang.String	ENV_OPERATOR_NAMESPACE	"OPERATOR_NAMESPACE"
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.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.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"

org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

Modifier and Type	Constant Field	Value
public static final java.lang.String	FIELD_NAME_TARGET_DIRECTORY	"target-directory"

org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

Modifier and Type	Constant Field	Value
public static final java.lang.String	FIELD_NAME_FORMAT_TYPE	"formatType"
public static final java.lang.String	FIELD_NAME_TARGET_DIRECTORY	"targetDirectory"