A B C D E F G H I J K L M N O P R S T U V W Y
All Classes All Packages

A

ABANDONED - org.apache.flink.kubernetes.operator.utils.SnapshotStatus

Manual snapshot is abandoned after defined retries.

AbstractFlinkDeploymentObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment

Base observer for session and application clusters.

AbstractFlinkDeploymentObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

AbstractFlinkResourceObserver<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.observer

Base observer for all Flink resources.

AbstractFlinkResourceObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

AbstractFlinkResourceReconciler<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<SPEC,STATUS>,SPEC extends org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec,STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Base class for all Flink resource reconcilers.

AbstractFlinkResourceReconciler(EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

AbstractFlinkService - Class in org.apache.flink.kubernetes.operator.service

An abstract FlinkService containing some common implementations for the native and standalone Flink Services.

AbstractFlinkService(KubernetesClient, ArtifactManager, ExecutorService, FlinkOperatorConfiguration) - Constructor for class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

AbstractJobReconciler<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<SPEC,STATUS>,SPEC extends org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec,STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Reconciler responsible for handling the job lifecycle according to the desired and current states.

AbstractJobReconciler(EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

AbstractJobReconciler.AvailableUpgradeMode - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Object to capture available upgrade mode.

addStartupProbe(Pod) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

allCanariesHealthy() - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

ALREADY_SCALED - org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

append(String, DiffResult<?>) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, Object[], Object[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, Object, Object, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, S, S, BiFunction<S, S, Boolean>, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

APPLICATION - org.apache.flink.kubernetes.operator.config.Mode

ApplicationObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment

The observer of Mode.APPLICATION cluster.

ApplicationObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver

applicationProtocolNegotiator() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

ApplicationReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Reconciler Flink Application deployments.

ApplicationReconciler(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

applyFlinkConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyImage() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyImagePullPolicy() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyIngressDomain() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyJobManagerSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyJobOrSessionSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyLogConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyPodTemplate() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyResourceToPodTemplate(Pod, Resource) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyServiceAccount() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyTaskManagerSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyValidationErrorAndResetSpec(FlinkResourceContext<? extends AbstractFlinkResource<SPEC, ?>>, String) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

In case of validation errors we need to (temporarily) reset the old spec so that we can reconcile other outstanding changes, instead of simply blocking.

ArtifactFetcher - Interface in org.apache.flink.kubernetes.operator.artifact

The artifact fetcher.

artifactManager - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

ArtifactManager - Class in org.apache.flink.kubernetes.operator.artifact

Manage the user artifacts.

ArtifactManager(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.artifact.ArtifactManager

AuditUtils - Class in org.apache.flink.kubernetes.operator.listener

Responsible for logging resource event/status updates.

AuditUtils() - Constructor for class org.apache.flink.kubernetes.operator.listener.AuditUtils

autoscaler - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

AutoscalerError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

AutoscalerFactory - Class in org.apache.flink.kubernetes.operator.autoscaler

The factory of JobAutoScaler.

AutoscalerFactory() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFactory

AvailableUpgradeMode() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.AvailableUpgradeMode

B

build() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

build() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

build() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder

buildFrom(String, String, FlinkDeploymentSpec, Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

C

calculateClusterCpuUsage(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

calculateClusterMemoryUsage(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

CANARY_LABEL - Static variable in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

CANARY_RESOURCE_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

CanaryResourceManager<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.health

Logic encapsulating canary tests.

CanaryResourceManager() - Constructor for class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

cancelJob(FlinkDeployment, UpgradeMode, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

cancelJob(FlinkResourceContext<CR>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

Cancel the job for the given resource using the specified upgrade mode.

cancelJob(FlinkResourceContext<FlinkDeployment>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

cancelJob(FlinkResourceContext<FlinkSessionJob>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

cancelSessionJob(FlinkSessionJob, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

cancelSessionJob(FlinkSessionJob, UpgradeMode, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

CANNOT_SCALE - org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

changeLastStateIfCheckpointTooOld(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

channelRead0(ChannelHandlerContext, HttpObject) - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthHandler

checkAndUpdateStableSpec(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Checks the status and if the corresponding Flink job/application is in stable running state, it updates the last stable spec.

checkHealth(ResourceID, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

checkIfAlreadyUpgraded(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

Checks a resource that is currently in the UPGRADING state whether it was already deployed but we simply miss the status information.

checkIfAlreadyUpgraded(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

checkIfAlreadyUpgraded(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

CHECKPOINT - org.apache.flink.kubernetes.operator.reconciler.SnapshotType

CheckpointError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

CheckpointFetchResult - Class in org.apache.flink.kubernetes.operator.observer

Result of a fetch checkpoint operation.

CheckpointFetchResult() - Constructor for class org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult

CheckpointHistoryWrapper - Class in org.apache.flink.kubernetes.operator.service

Custom Response for handling checkpoint history in a multi-version compatible way.

CheckpointHistoryWrapper() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper

CheckpointHistoryWrapper.CompletedCheckpointInfo - Class in org.apache.flink.kubernetes.operator.service

Information about the latest completed checkpoint/savepoint.

CheckpointHistoryWrapper.PendingCheckpointInfo - Class in org.apache.flink.kubernetes.operator.service

Information about the currently pending checkpoint/savepoint.

checkpointInProgress(JobStatus) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

cipherSuites() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

cleanup(CR) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

cleanup(FlinkDeployment, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

cleanup(FlinkSessionJob, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

cleanup(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

cleanup(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.Reconciler

This is called when receiving the delete event of custom resource.

Cleanup - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

cleanupAfterFailedJob(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

Removes a failed job.

cleanupAfterFailedJob(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

cleanupAfterFailedJob(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

cleanupDoneFor(ResourceID, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

CleanupFailed - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

cleanupInternal(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Shut down and clean up all Flink job/cluster resources.

cleanupInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

cleanupInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

cleanupInternal(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

cleanupTmpFiles(Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

clearAll(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

clearAll(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

clearErrorsIfDeploymentIsHealthy(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

clearLastReconciledSpecIfFirstDeploy(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Clear last reconciled spec if that corresponds to the first deployment.

clock - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

clone(T) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

ClusterHealthEvaluator - Class in org.apache.flink.kubernetes.operator.observer

Evaluates whether the cluster is healthy.

ClusterHealthEvaluator(Clock) - Constructor for class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

ClusterHealthInfo - Class in org.apache.flink.kubernetes.operator.health

Represents information about job health.

ClusterHealthInfo() - Constructor for class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

ClusterHealthInfo(Clock) - Constructor for class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

ClusterHealthObserver - Class in org.apache.flink.kubernetes.operator.observer

An observer to observe the cluster health.

ClusterHealthObserver() - Constructor for class org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver

COLLECTED_METRICS_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

completed() - Static method in class org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult

completed(String) - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult

CompletedCheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.CompletedCheckpointInfo

configManager - Variable in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

ConfigMapStore - Class in org.apache.flink.kubernetes.operator.autoscaler.state

The ConfigMapStore persists state in Kubernetes ConfigMaps.

ConfigMapStore(KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

ConfigOptionUtils - Class in org.apache.flink.kubernetes.operator.utils

ConfigOption utilities.

ConfigOptionUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils

COUNTER - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

COUNTER_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

COUNTER_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

CPU_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

CR_GENERATION_LABEL - Static variable in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

create(KubernetesClient, Collection<FlinkResourceListener>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

create(KubernetesClient, MetricManager<CR>, Collection<FlinkResourceListener>) - Static method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

create(KubernetesClient, EventRecorder) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFactory

create(MetricRegistry, Configuration, String, String, String) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

createFlinkDeploymentMetricManager(Configuration, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

createFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

createFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

createFlinkSessionJobMetricManager(Configuration, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

createHistogram(FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

createIfNotExists(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils

createMetricConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

createNamespacedKubeClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Generate the config that is currently deployed for the resource spec.

createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

createOperator() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator

createOrUpdateEventWithInterval(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>, String, Duration) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils

createOrUpdateEventWithLabels(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>, String, Duration, Predicate<Map<String, String>>, Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils

createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup

createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

createResourceGroup(Configuration, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

createResourceMetricGroup(KubernetesOperatorMetricGroup, FlinkConfigManager, AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

createResourceNamespaceGroup(Configuration, Class<? extends AbstractFlinkResource>, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

CustomCheckpointingStatisticsHeaders - Class in org.apache.flink.kubernetes.operator.service

Custom Headers for handling checkpoint history in a multi-version compatible way.

CustomCheckpointingStatisticsHeaders() - Constructor for class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

CustomDashboardConfiguration - Class in org.apache.flink.kubernetes.operator.service

Custom Response for handling dashboard configs.

CustomDashboardConfiguration() - Constructor for class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration

CustomDashboardConfigurationHeaders - Class in org.apache.flink.kubernetes.operator.service

Message headers for the CustomDashboardConfiguration.

CustomResourceMetrics<CR extends io.fabric8.kubernetes.client.CustomResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.metrics

Custom resource metric type.

D

dec() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

dec(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

DEFAULT_CHECKPOINTING_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

DefaultValidator - Class in org.apache.flink.kubernetes.operator.validation

Default validator implementation for FlinkDeployment.

DefaultValidator(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.validation.DefaultValidator

deleteClusterDeployment(ObjectMeta, FlinkDeploymentStatus, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

deleteClusterDeployment(ObjectMeta, FlinkDeploymentStatus, Configuration, boolean) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

Delete Flink kubernetes cluster by deleting the kubernetes resources directly.

deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

deleteHAData(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

deleteJobGraphInKubernetesHA(String, String, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

deleteJobGraphInZookeeperHA(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

deleteKubernetesHAMetadata(String, String, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

deleteZookeeperHAMetadata(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

deploy(FlinkResourceContext<CR>, SPEC, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Deploys the target resource spec to Kubernetes.

deploy(FlinkResourceContext<FlinkDeployment>, FlinkDeploymentSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

deploy(FlinkResourceContext<FlinkDeployment>, FlinkDeploymentSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

deploy(FlinkResourceContext<FlinkSessionJob>, FlinkSessionJobSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

DEPLOYMENT_READINESS_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

DEPLOYMENT_ROLLBACK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

DeploymentFailedException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal terminal deployment failure.

DeploymentFailedException(DeploymentCondition) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

DeploymentFailedException(ContainerStateWaiting) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

DeploymentFailedException(String, String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

deserialize(String) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

Diff<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff

Contains the differences between two Diffable class fields.

Diff() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.Diff

DiffBuilder<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff

Assists in implementing comparison of Diffable instances.

DiffBuilder(T, T) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

DiffResult<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff

Contains a collection of the differences between two Diffable objects.

discoverListeners(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.listener.ListenerUtils

Load FlinkResourceListener implementations from the plugin directory.

discoverValidators(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.utils.ValidatorUtils

disposeSavepoint(String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

disposeSavepoint(String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

DRAIN_ON_SAVEPOINT_DELETION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

E

ENV_CONF_OVERRIDE_DIR - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_HOSTNAME - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_KUBERNETES_SERVICE_HOST - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_OPERATOR_NAME - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_OPERATOR_NAMESPACE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WATCH_NAMESPACES - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WEBHOOK_KEYSTORE_FILE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WEBHOOK_KEYSTORE_PASSWORD - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WEBHOOK_KEYSTORE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WEBHOOK_SERVER_PORT - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

EnvUtils - Class in org.apache.flink.kubernetes.operator.utils

Util to get value from environments.

EnvUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EnvUtils

equals(Object) - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

error(String) - Static method in class org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult

error(String) - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult

evaluate(Configuration, Map<String, String>, ClusterHealthInfo) - Method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

eventRecorder - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

eventRecorder - Variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

eventRecorder - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

EventRecorder - Class in org.apache.flink.kubernetes.operator.utils

Helper class for creating Kubernetes events for Flink resources.

EventRecorder(BiConsumer<AbstractFlinkResource<?, ?>, Event>) - Constructor for class org.apache.flink.kubernetes.operator.utils.EventRecorder

EventRecorder.Component - Enum in org.apache.flink.kubernetes.operator.utils

The component of events.

EventRecorder.Reason - Enum in org.apache.flink.kubernetes.operator.utils

The reason codes of events.

EventRecorder.Type - Enum in org.apache.flink.kubernetes.operator.utils

The type of the events.

EventSourceUtils - Class in org.apache.flink.kubernetes.operator.utils

Utility class to locate secondary resources.

EventSourceUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EventSourceUtils

EventUtils - Class in org.apache.flink.kubernetes.operator.utils

The util to generate an event for the target resource.

EventUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EventUtils

executorService - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

F

failedReconciliation(ResourceID, Exception, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

fetch(String, Configuration, File) - Method in interface org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher

Fetch the resource from the uri to the targetDir.

fetch(String, Configuration, File) - Method in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher

fetch(String, Configuration, File) - Method in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher

fetch(String, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.artifact.ArtifactManager

fetchCheckpointInfo(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

fetchCheckpointInfo(String, String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

fetchSavepointInfo(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

fetchSavepointInfo(String, String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

FIELD_NAME_ACC_BACK_PRESSURE - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_ACC_BUSY - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_ACC_IDLE - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_BYTES_READ - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_BYTES_WRITTEN - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_FLINK_REVISION - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration

FIELD_NAME_FLINK_VERSION - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration

FIELD_NAME_FORMAT_TYPE - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

FIELD_NAME_RECORDS_READ - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_RECORDS_WRITTEN - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_TARGET_DIRECTORY - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

FIELD_NAME_TARGET_DIRECTORY - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

FIELD_NAME_TOTAL_CPU - Static variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

FIELD_NAME_TOTAL_MEMORY - Static variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

FileSystemBasedArtifactFetcher - Class in org.apache.flink.kubernetes.operator.artifact

Leverage the flink filesystem plugin to fetch the artifact.

FileSystemBasedArtifactFetcher() - Constructor for class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher

FileSystemWatchService - Class in org.apache.flink.kubernetes.operator.fs

Service which is able to watch local filesystem directories.

FileSystemWatchService(String) - Constructor for class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

filterTargetJob(JobStatus, List<JobStatusMessage>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Filter the target job status message by the job list from the cluster.

findExistingEvent(KubernetesClient, HasMetadata, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils

finishedReconciliation(ResourceID, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

FLINK_VERSION - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

FLINK_VERSION_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

FlinkConfigBuilder - Class in org.apache.flink.kubernetes.operator.config

Builder to get effective flink config from FlinkDeployment.

FlinkConfigBuilder(String, String, FlinkDeploymentSpec, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

FlinkConfigBuilder(FlinkDeployment, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

FlinkConfigManager - Class in org.apache.flink.kubernetes.operator.config

Configuration manager for the Flink operator.

FlinkConfigManager(Consumer<Set<String>>) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

FlinkConfigManager(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

FlinkConfigManager(Configuration, Consumer<Set<String>>) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

FlinkDeploymentContext - Class in org.apache.flink.kubernetes.operator.controller

Context for reconciling a Flink resource.

FlinkDeploymentContext(FlinkDeployment, Context<?>, KubernetesResourceMetricGroup, FlinkConfigManager, Function<FlinkResourceContext<?>, FlinkService>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

FlinkDeploymentController - Class in org.apache.flink.kubernetes.operator.controller

Controller that runs the main reconcile loop for Flink deployments.

FlinkDeploymentController(Set<FlinkResourceValidator>, FlinkResourceContextFactory, ReconcilerFactory, FlinkDeploymentObserverFactory, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, EventRecorder, CanaryResourceManager<FlinkDeployment>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

FlinkDeploymentMetrics - Class in org.apache.flink.kubernetes.operator.metrics

FlinkDeployment metrics.

FlinkDeploymentMetrics(KubernetesOperatorMetricGroup, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

FlinkDeploymentObserverFactory - Class in org.apache.flink.kubernetes.operator.observer.deployment

The factory to create the observer based on the FlinkDeployment mode.

FlinkDeploymentObserverFactory(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory

FlinkOperator - Class in org.apache.flink.kubernetes.operator

Main Class for Flink native k8s operator.

FlinkOperator(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.FlinkOperator

FlinkOperatorConfiguration - Class in org.apache.flink.kubernetes.operator.config

Configuration class for operator.

FlinkOperatorConfiguration() - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration

FlinkResourceContext<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.controller

Context for reconciling a Flink resource.

FlinkResourceContext() - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

FlinkResourceContextFactory - Class in org.apache.flink.kubernetes.operator.service

Factory for creating the FlinkResourceContext.

FlinkResourceContextFactory(FlinkConfigManager, KubernetesOperatorMetricGroup, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

FlinkResourceException - Class in org.apache.flink.kubernetes.operator.exception

Exception to display as JSON in CRD.

FlinkResourceException() - Constructor for class org.apache.flink.kubernetes.operator.exception.FlinkResourceException

FlinkResourceExceptionUtils - Class in org.apache.flink.kubernetes.operator.utils

Flink Resource Exception utilities.

FlinkResourceExceptionUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

FlinkResourceValidator - Interface in org.apache.flink.kubernetes.operator.validation

Validator for different resources.

FlinkService - Interface in org.apache.flink.kubernetes.operator.service

Service for submitting and interacting with Flink clusters and jobs.

FlinkService.ScalingResult - Enum in org.apache.flink.kubernetes.operator.service

Result of an in-place scaling operation.

FlinkSessionJobContext - Class in org.apache.flink.kubernetes.operator.controller

Context for reconciling a Flink resource.

FlinkSessionJobContext(FlinkSessionJob, Context<?>, KubernetesResourceMetricGroup, FlinkConfigManager, Function<FlinkResourceContext<?>, FlinkService>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

FlinkSessionJobController - Class in org.apache.flink.kubernetes.operator.controller

Controller that runs the main reconcile loop for FlinkSessionJob.

FlinkSessionJobController(Set<FlinkResourceValidator>, FlinkResourceContextFactory, Reconciler<FlinkSessionJob>, Observer<FlinkSessionJob>, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>, EventRecorder, CanaryResourceManager<FlinkSessionJob>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

FlinkSessionJobMetrics - Class in org.apache.flink.kubernetes.operator.metrics

FlinkSessionJob metrics.

FlinkSessionJobMetrics(KubernetesOperatorMetricGroup, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

FlinkSessionJobObserver - Class in org.apache.flink.kubernetes.operator.observer.sessionjob

The observer of FlinkSessionJob.

FlinkSessionJobObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

FlinkUtils - Class in org.apache.flink.kubernetes.operator.utils

Flink Utility methods used by the operator.

FlinkUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.FlinkUtils

flinkVersionChanged(SPEC, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

flush(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

flush(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

format(Event) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils

formatScope(String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

formatScope(String, String, String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

formatScope(String, String, String, String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

from - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

fromConfig(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService

fromConfiguration(Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration

fromRuntimeInfo(RuntimeInfo) - Static method in class org.apache.flink.kubernetes.operator.health.InformerHealthSummary

G

GENERATED_FILE_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

generateEventName(HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils

generateJarDir(ObjectMeta, FlinkSessionJobSpec) - Method in class org.apache.flink.kubernetes.operator.artifact.ArtifactManager

generateSessionJobFixedJobID(ObjectMeta) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

The jobID's lower part is the resource uid, the higher part is the resource generation.

generateSessionJobFixedJobID(String, Long) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

The jobID's lower part is the resource uid, the higher part is the resource generation.

get(String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils

Get the value provided by environments.

getAccumulatedBackpressured() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getAccumulatedBusy() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getAccumulatedIdle() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getAvailableUpgradeMode(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

getAvailableUpgradeMode(FlinkResourceContext<FlinkDeployment>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

getBytesRead() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getBytesWritten() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getCache() - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

getCache() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getCheckpointInfo(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getCheckpointInfo(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getClusterClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getClusterClient(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getClusterInfo(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getClusterInfo(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getCollectedMetrics(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram

getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

getCurrentState() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

getDefaultConfig() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getDefaultConfig(String, FlinkVersion) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

Get the base configuration for the given namespace and flink version combination.

getDeployConfig(ObjectMeta, FlinkDeploymentSpec) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

Get deployment configuration that will be passed to the Flink Cluster clients during cluster submission.

getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Get Flink configuration object for deploying the given spec using AbstractFlinkResourceReconciler.deploy(org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<CR>, SPEC, org.apache.flink.configuration.Configuration, java.util.Optional<java.lang.String>, boolean).

getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

getDeployedSpec(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

getDeploymentInformerEventSource(EventSourceContext<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils

getDeploymentMode() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

getDeploymentMode() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

getDeploymentMode() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

getDescription() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getDescription() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getEffectiveStatus(JobDetails) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getFlinkDeploymentInformerEventSource(EventSourceContext<FlinkSessionJob>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils

getFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Get the FlinkService implementation for the current resource.

getFlinkService(FlinkResourceContext<?>) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

getFlinkVersion() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

getFlinkVersion() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

getFlinkVersion() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

getFormatType() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

getFormatType() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup

getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

getHttpMethod() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getHttpMethod() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getIngressUrl(String, String, String) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils

getInProgressCheckpoint() - Method in class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper

getInstance() - Static method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getInstance() - Static method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

getJmPodList(FlinkDeployment, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getJmPodList(FlinkDeployment, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getJobAutoScalerContext() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

getJobDetailsInfo(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getJobDetailsInfo(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext

getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Get KubernetesClient available from JOSDK Context.

getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getKubernetesClient() - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getKubernetesClient(FlinkOperatorConfiguration, MetricGroup) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils

getKubernetesClient(FlinkOperatorConfiguration, MetricGroup, Config) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils

getLastCheckpoint(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getLastCheckpoint(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getLastSnapshotStatus(AbstractFlinkResource<?, ?>, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

getLastValidClusterHealthInfo(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

getLatestCompletedCheckpoint() - Method in class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper

getLifecycleTrackers() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

getMetrics(Configuration, String, List<String>) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getMetrics(Configuration, String, List<String>) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getMode(FlinkDeployment) - Static method in enum org.apache.flink.kubernetes.operator.config.Mode

Return the mode of the given FlinkDeployment for Observer and Reconciler.

getNumberOfActiveCanaries() - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

getNumDiffs() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult

getNumTaskManagers(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

getNumTaskManagers(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

getObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Get the config that is currently deployed for the resource spec.

getObserveConfig(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

Get the observe configuration that can be used to interact with already submitted clusters through the Flink rest clients.

getOperator() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator

getOperatorConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

getOperatorConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getOperatorConfiguration(String, FlinkVersion) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

Get the operator configuration for the given namespace and flink version combination.

getOrCreate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory

getOrCreate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory

getOrDefault(String, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils

Get the value or default value provided by environments.

getParallelismOverrides(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

getRate() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

getReason() - Method in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

getReason() - Method in exception org.apache.flink.kubernetes.operator.exception.RecoveryFailureException

getRecordsRead() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getRecordsWritten() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getRegisteredMetrics() - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

getRequestClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getRequestClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getRequired(String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils

Get the value provided by environments.

getResource() - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext

getResourceContext(CR, Context) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

getResponseClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getResponseClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getResponseStatusCode() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getResponseStatusCode() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getRestClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getScalingHistory(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

getSerializedState(KubernetesJobAutoScalerContext, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

getSessionJobConfig(FlinkDeployment, FlinkSessionJobSpec) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

Get configuration for interacting with session jobs.

getSessionJobInformerEventSource(EventSourceContext<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils

getStateTimeHistos() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

getStatistics() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram

getSubstringWithMaxLength(String, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

getTargetDirectory() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

getTargetDirectory() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

getTargetRestEndpointURL() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getTmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getTmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

getTmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

getTransitionHistos() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

getTriggerId() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

getTriggerId() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

getUnresolvedMessageParameters() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getUpgradeTargetGeneration(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Get spec generation for the current in progress upgrade.

getValueWithThreshold(Configuration, ConfigOption<T>, T) - Static method in class org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils

Gets the value of ConfigOption with threshold.

getVertexResources(RestClusterClient<String>, AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

gracePeriodEnded(Duration, SnapshotInfo) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

H

handleCanaryResourceDeletion(CR) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

handleCanaryResourceReconciliation(CR, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

handleEvent(KubernetesJobAutoScalerContext, AutoScalerEventHandler.Type, String, String, String, Duration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler

handleScalingEvent(KubernetesJobAutoScalerContext, Map<JobVertexID, ScalingSummary>, boolean, Duration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler

hashCode() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

HealthProbe - Enum in org.apache.flink.kubernetes.operator.health

Flink operator health probe.

HISTO - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

hostname - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

HTTP_REQUEST_FAILED_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_REQUEST_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_1XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_2XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_3XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_4XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_5XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HttpArtifactFetcher - Class in org.apache.flink.kubernetes.operator.artifact

Download the jar from the http resource.

HttpArtifactFetcher() - Constructor for class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher

HttpBootstrap - Class in org.apache.flink.kubernetes.operator.health

Class for serving HTTP requests for the health probe.

HttpBootstrap(HealthProbe, int) - Constructor for class org.apache.flink.kubernetes.operator.health.HttpBootstrap

I

inc() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

inc(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

IneffectiveScaling - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

InformerHealthSummary - Class in org.apache.flink.kubernetes.operator.health

Operator informer health summary.

InformerHealthSummary() - Constructor for class org.apache.flink.kubernetes.operator.health.InformerHealthSummary

InformerIdentifier - Class in org.apache.flink.kubernetes.operator.health

Operator informer identifier.

InformerIdentifier() - Constructor for class org.apache.flink.kubernetes.operator.health.InformerIdentifier

ingressInNetworkingV1(KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils

IngressUtils - Class in org.apache.flink.kubernetes.operator.utils

Ingress utilities.

IngressUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.IngressUtils

initOperatorMetrics(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

INSTANCE - org.apache.flink.kubernetes.operator.health.HealthProbe

INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher

INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher

INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

intercept(Interceptor.Chain) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

IOMetricsInfo - Class in org.apache.flink.runtime.rest.messages.job.metrics

IO metrics information.

IOMetricsInfo(long, boolean, long, boolean, long, boolean, long, boolean, Long, Long, Double) - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isAvailable() - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.AvailableUpgradeMode

isBytesReadComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isBytesWrittenComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isCanaryResource(HasMetadata) - Static method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

isCancelJob() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

isClient() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

isHaMetadataAvailable(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

isHaMetadataAvailable(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

isHealthy() - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

isJmDeploymentReady(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

isJobInTerminalState(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

isJobManagerPortReady(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

isJobManagerPortReady(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

isJobRunning(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

isKubernetesHAActivated(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

isKubernetesHaMetadataAvailable(Configuration, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

isRecordsReadComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isRecordsWrittenComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isResourceReadyToBeObserved(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

Check whether the resource should be observed.

isResourceReadyToBeObserved(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

isSnapshotTriggeringSupported(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

isSuspendedJob(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

isUpgradeModeChangedToLastStateAndHADisabledPreviously(AbstractFlinkResource<?, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

isValid(ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

isZookeeperHAActivated(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

isZookeeperHaMetadataAvailable(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

J

JAR_ARTIFACT_HTTP_HEADER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

jmPodNeverStarted(Context<?>) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

Check if the jobmanager pod has never successfully started.

Job - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

JOB_UPGRADE_IGNORE_PENDING_SAVEPOINT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

JOB_UPGRADE_INPLACE_SCALING_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

JobManagerDeployment - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

JobStatusChanged - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

JobStatusObserver<R extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.observer

An observer to observe the job status.

JobStatusObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

K

K8S_OP_CONF_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

KUBE_CLIENT_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

KubernetesAutoScalerEventHandler - Class in org.apache.flink.kubernetes.operator.autoscaler

An event handler which posts events to the Kubernetes events API.

KubernetesAutoScalerEventHandler(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler

KubernetesAutoScalerStateStore - Class in org.apache.flink.kubernetes.operator.autoscaler.state

An AutoscalerStateStore which persists its state in Kubernetes ConfigMaps.

KubernetesAutoScalerStateStore(ConfigMapStore) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

kubernetesClient - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

KubernetesClientMetrics - Class in org.apache.flink.kubernetes.operator.metrics

Kubernetes client metrics.

KubernetesClientMetrics(MetricGroup, FlinkOperatorConfiguration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

KubernetesClientUtils - Class in org.apache.flink.kubernetes.operator.utils

Kubernetes client utils.

KubernetesClientUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils

KubernetesJobAutoScalerContext - Class in org.apache.flink.kubernetes.operator.autoscaler

An implementation of JobAutoscalerContext for Kubernetes.

KubernetesJobAutoScalerContext(JobID, JobStatus, Configuration, MetricGroup, SupplierWithException<RestClusterClient<String>, Exception>, AbstractFlinkResource<?, ?>, KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext

KubernetesOperatorConfigOptions - Class in org.apache.flink.kubernetes.operator.config

This class holds configuration constants used by flink operator.

KubernetesOperatorConfigOptions() - Constructor for class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

KubernetesOperatorMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics

Base metric group for Flink Operator System metrics.

KubernetesOperatorMetricOptions - Class in org.apache.flink.kubernetes.operator.metrics

Configuration options for metrics.

KubernetesOperatorMetricOptions() - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

KubernetesOperatorScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics

Format for metrics.

KubernetesOperatorScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

KubernetesResourceMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics

Base metric group for Flink Operator Resource level metrics.

KubernetesResourceMetricGroup(MetricRegistry, KubernetesResourceNamespaceMetricGroup, String[], String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup

KubernetesResourceNamespaceMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics

Base metric group for Flink Operator Resource namespace level metrics.

KubernetesResourceNamespaceMetricGroup(MetricRegistry, KubernetesOperatorMetricGroup, String[], String, String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

KubernetesResourceNamespaceScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics

Format for metrics.

KubernetesResourceNamespaceScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

KubernetesResourceScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics

Format for metrics.

KubernetesResourceScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

KubernetesScalingRealizer - Class in org.apache.flink.kubernetes.operator.autoscaler

The Kubernetes implementation for applying parallelism overrides.

KubernetesScalingRealizer() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer

L

LABELS - Static variable in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

LifecycleMetrics<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle

Utility for tracking resource lifecycle metrics globally and per namespace.

LifecycleMetrics(Configuration, KubernetesOperatorMetricGroup) - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

LifecycleMetrics.Transition - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle

Pojo for encapsulating state transitions and whether we should measure time from the beginning of from or since the last update.

ListenerUtils - Class in org.apache.flink.kubernetes.operator.listener

Flink resource listener utilities.

ListenerUtils() - Constructor for class org.apache.flink.kubernetes.operator.listener.ListenerUtils

listJobs(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

listJobs(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

loadGlobalConfiguration(Optional<String>) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

loadListenerConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.listener.ListenerUtils

LOG - Static variable in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher

LOG - Static variable in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher

logContext(FlinkResourceListener.ResourceEventContext<R>) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils

logContext(FlinkResourceListener.StatusUpdateContext<R, S>) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils

logEnvironmentInfo(Logger, String, String[]) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils

Logs information about the environment, like code revision, current user, Java version, and JVM parameters.

logger - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

logger - Variable in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

M

main(String...) - Static method in class org.apache.flink.kubernetes.operator.FlinkOperator

markEvent() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

markEvent(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

MAX_CM_BYTES - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

measureFromLastUpdate - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

MEMORY_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

mergePodTemplates(Pod, Pod, boolean) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

METER - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

MetricManager<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.metrics

Metric manager for Operator managed custom resources.

MetricManager() - Constructor for class org.apache.flink.kubernetes.operator.metrics.MetricManager

metricName - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

Missing - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

MISSING_SESSION_JOB_ERR - Static variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

MissingJobManagerException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal missing job manager.

MissingJobManagerException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException

MissingJobManagerException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException

MissingJobManagerException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException

MissingSessionJobException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal missing session job.

MissingSessionJobException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException

MissingSessionJobException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException

MissingSessionJobException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException

Mode - Enum in org.apache.flink.kubernetes.operator.config

The mode of FlinkDeployment.

monitorSizeOf(T, String) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

MSG_ROLLBACK - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

MSG_SPEC_CHANGED - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

MSG_SUBMIT - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

MSG_SUSPENDED - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

N

name - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

namespace - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

NAMESPACE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

NAMESPACE_CONF_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

NativeFlinkService - Class in org.apache.flink.kubernetes.operator.service

Implementation of FlinkService submitting and interacting with Native Kubernetes Flink clusters and jobs.

NativeFlinkService(KubernetesClient, ArtifactManager, ExecutorService, FlinkOperatorConfiguration, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.service.NativeFlinkService

newEngine(ByteBufAllocator) - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

newEngine(ByteBufAllocator, String, int) - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

Normal - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

O

objectMapper - Variable in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

observe(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

observe(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.observer.Observer

Observe the flinkApp status, It will reflect the changed status on the flinkApp resource.

observe(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver

Observe the health of the flink cluster.

observe(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Observe the status of the flink job.

observeCheckpointStatus(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.SnapshotObserver

observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

Observe the flinkApp status when the cluster is ready.

observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver

observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver

observeInternal(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

Internal observer logic specific to each resource type.

observeInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

observeInternal(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

observeJmDeployment(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

Observer<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.observer

The Observer of custom resource.

observeSavepointStatus(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.SnapshotObserver

onFileOrDirectoryCreated(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

onFileOrDirectoryDeleted(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

onFileOrDirectoryModified(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

onNoJobsFound(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Callback when no jobs were found on the cluster.

onRemove(CR) - Method in interface org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics

onRemove(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

onRemove(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

onRemove(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

onRemove(FlinkSessionJob) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

onTargetJobNotFound(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Callback when no matching target job was found on a cluster where jobs were found.

onTimeout(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Callback when list jobs timeout.

onUpdate(CR) - Method in interface org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics

onUpdate(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

onUpdate(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

onUpdate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

onUpdate(FlinkSessionJob) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

onUpdate(ResourceLifecycleState, Instant) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

onWatchStarted(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

Operator - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

OPERATOR_CHECKPOINT_TRIGGER_GRACE_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CHECKPOINT_TYPE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CONFIG_CACHE_SIZE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CONFIG_CACHE_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_DYNAMIC_CONFIG_CHECK_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_DYNAMIC_CONFIG_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_DYNAMIC_NAMESPACES_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_FIELD_MAX_LENGTH - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_LABEL_MAPPER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_STACK_TRACE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_STACK_TRACE_MAX_LENGTH - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_THROWABLE_LIST_MAX_COUNT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_FLINK_CLIENT_CANCEL_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_FLINK_CLIENT_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_HEALTH_PROBE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_HEALTH_PROBE_PORT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JM_DEPLOYMENT_RECOVERY_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JM_SHUTDOWN_TTL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JM_STARTUP_PROBE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JOB_RESTART_FAILED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JOB_UPGRADE_LAST_STATE_CHECKPOINT_MAX_AGE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JOB_UPGRADE_LAST_STATE_FALLBACK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JOSDK_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_JVM_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_KUBERNETES_CLIENT_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_KUBERNETES_CLIENT_METRICS_HTTP_RESPONSE_CODE_GROUPS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_LABEL_SELECTOR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_LEASE_DURATION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_LEASE_NAME - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_RENEW_DEADLINE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_RETRY_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LIFECYCLE_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_LIFECYCLE_NAMESPACE_HISTOGRAMS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_METRICS_HISTOGRAM_SAMPLE_SIZE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_OBSERVER_PROGRESS_CHECK_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_OBSERVER_REST_READY_DELAY - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RATE_LIMITER_LIMIT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RATE_LIMITER_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RECONCILE_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RECONCILE_PARALLELISM - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RESOURCE_CLEANUP_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RESOURCE_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_RETRY_INITIAL_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RETRY_INTERVAL_MULTIPLIER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RETRY_MAX_ATTEMPTS - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RETRY_MAX_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_CLEANUP_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_FORMAT_TYPE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_HISTORY_MAX_AGE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_HISTORY_MAX_AGE_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_TRIGGER_GRACE_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_STOP_ON_INFORMER_ERROR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_TERMINATION_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_USER_ARTIFACTS_BASE_DIR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_WATCHED_NAMESPACES - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

operatorConfig - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

operatorConfig(String) - Static method in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

operatorConfigKey(String) - Static method in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OperatorHealthHandler - Class in org.apache.flink.kubernetes.operator.health

Simple code which returns HTTP 200 messages if the service is live, and HTTP 500 messages if the service is down.

OperatorHealthHandler() - Constructor for class org.apache.flink.kubernetes.operator.health.OperatorHealthHandler

OperatorHealthService - Class in org.apache.flink.kubernetes.operator.health

Health probe service.

OperatorHealthService(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.health.OperatorHealthService

OperatorJosdkMetrics - Class in org.apache.flink.kubernetes.operator.metrics

Implementation of Metrics to monitor and forward JOSDK metrics to MetricRegistry.

OperatorJosdkMetrics(KubernetesOperatorMetricGroup, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

OperatorMetricUtils - Class in org.apache.flink.kubernetes.operator.metrics

Utility class for flink based operator metrics.

OperatorMetricUtils() - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

OperatorMetricUtils.SynchronizedCounter - Class in org.apache.flink.kubernetes.operator.metrics

Thread safe Counter wrapper.

OperatorMetricUtils.SynchronizedHistogram - Class in org.apache.flink.kubernetes.operator.metrics

Thread safe Histogram wrapper.

OperatorMetricUtils.SynchronizedMeterView - Class in org.apache.flink.kubernetes.operator.metrics

Thread safe MeterView wrapper.

org.apache.flink.kubernetes.operator - package org.apache.flink.kubernetes.operator

org.apache.flink.kubernetes.operator.artifact - package org.apache.flink.kubernetes.operator.artifact

org.apache.flink.kubernetes.operator.autoscaler - package org.apache.flink.kubernetes.operator.autoscaler

org.apache.flink.kubernetes.operator.autoscaler.state - package org.apache.flink.kubernetes.operator.autoscaler.state

org.apache.flink.kubernetes.operator.config - package org.apache.flink.kubernetes.operator.config

org.apache.flink.kubernetes.operator.controller - package org.apache.flink.kubernetes.operator.controller

org.apache.flink.kubernetes.operator.exception - package org.apache.flink.kubernetes.operator.exception

org.apache.flink.kubernetes.operator.fs - package org.apache.flink.kubernetes.operator.fs

org.apache.flink.kubernetes.operator.health - package org.apache.flink.kubernetes.operator.health

org.apache.flink.kubernetes.operator.listener - package org.apache.flink.kubernetes.operator.listener

org.apache.flink.kubernetes.operator.metrics - package org.apache.flink.kubernetes.operator.metrics

org.apache.flink.kubernetes.operator.metrics.lifecycle - package org.apache.flink.kubernetes.operator.metrics.lifecycle

org.apache.flink.kubernetes.operator.observer - package org.apache.flink.kubernetes.operator.observer

org.apache.flink.kubernetes.operator.observer.deployment - package org.apache.flink.kubernetes.operator.observer.deployment

org.apache.flink.kubernetes.operator.observer.sessionjob - package org.apache.flink.kubernetes.operator.observer.sessionjob

org.apache.flink.kubernetes.operator.reconciler - package org.apache.flink.kubernetes.operator.reconciler

org.apache.flink.kubernetes.operator.reconciler.deployment - package org.apache.flink.kubernetes.operator.reconciler.deployment

org.apache.flink.kubernetes.operator.reconciler.diff - package org.apache.flink.kubernetes.operator.reconciler.diff

org.apache.flink.kubernetes.operator.reconciler.sessionjob - package org.apache.flink.kubernetes.operator.reconciler.sessionjob

org.apache.flink.kubernetes.operator.service - package org.apache.flink.kubernetes.operator.service

org.apache.flink.kubernetes.operator.ssl - package org.apache.flink.kubernetes.operator.ssl

org.apache.flink.kubernetes.operator.utils - package org.apache.flink.kubernetes.operator.utils

org.apache.flink.kubernetes.operator.validation - package org.apache.flink.kubernetes.operator.validation

org.apache.flink.runtime.rest.messages.job.metrics - package org.apache.flink.runtime.rest.messages.job.metrics

org.apache.flink.runtime.rest.messages.job.savepoints - package org.apache.flink.runtime.rest.messages.job.savepoints

org.apache.flink.runtime.rest.messages.job.savepoints.stop - package org.apache.flink.runtime.rest.messages.job.savepoints.stop

P

PARALLELISM_MAP_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler

PARALLELISM_OVERRIDES_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

parseResourceMemoryString(String) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

patchAndCacheStatus(CR, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

Update the status of the provided kubernetes resource on the k8s cluster.

pending() - Static method in class org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult

pending() - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult

PENDING - org.apache.flink.kubernetes.operator.utils.SnapshotStatus

Snapshot is pending, could be in the retry phase in the case of manual snapshots.

PendingCheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.PendingCheckpointInfo

PERIODIC_CHECKPOINT_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

PERIODIC_SAVEPOINT_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

POD_TEMPLATE_MERGE_BY_NAME - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

prepareEventSources(EventSourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

prepareEventSources(EventSourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

putSerializedState(KubernetesJobAutoScalerContext, String, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup

putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

R

readyToReconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Check whether the given Flink resource is ready to be reconciled or we are still waiting for any pending operation or condition first.

readyToReconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

readyToReconcile(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

readyToReconcile(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

realize(KubernetesJobAutoScalerContext, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer

REASON_CRASH_LOOP_BACKOFF - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

REASON_ERR_IMAGE_PULL - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

REASON_IMAGE_PULL_BACKOFF - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

receivedEvent(Event, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

reconcile(FlinkDeployment, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

reconcile(FlinkSessionJob, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

reconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

reconcile(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.Reconciler

This is called when receiving the create or update event of the custom resource.

reconcileCustomResource(ResourceID, RetryInfo, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

reconcileOtherChanges(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Reconcile any other changes required for this resource that are specific to the reconciler implementation.

reconcileOtherChanges(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

reconcileOtherChanges(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

reconcileOtherChanges(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

Reconciler<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.reconciler

The interface of reconciler.

ReconcilerFactory - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

The factory to create reconciler based on app mode.

ReconcilerFactory(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory

reconcileSpecChange(FlinkResourceContext<CR>, Configuration, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Reconcile spec upgrade on the currently deployed/suspended Flink resource and update the status accordingly.

reconcileSpecChange(FlinkResourceContext<CR>, Configuration, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

reconcileSpecChange(FlinkResourceContext<FlinkDeployment>, Configuration, FlinkDeploymentSpec) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

ReconciliationException - Exception in org.apache.flink.kubernetes.operator.exception

Exception for wrapping reconciliation errors.

ReconciliationException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException

ReconciliationException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException

ReconciliationException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException

ReconciliationUtils - Class in org.apache.flink.kubernetes.operator.reconciler

Reconciliation utilities.

ReconciliationUtils() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

RecoverDeployment - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

RecoveryFailureException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal non-terminal deployment failure.

RecoveryFailureException(String, String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.RecoveryFailureException

ReflectiveDiffBuilder<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff

Assists in comparing Diffable objects with reflection.

ReflectiveDiffBuilder(KubernetesDeploymentMode, T, T) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder

register(CustomResourceMetrics<CR>) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

registerCanaryResourceManager(CanaryResourceManager<?>) - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

reload() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

ReloadableSslContext - Class in org.apache.flink.kubernetes.operator.ssl

SSL context which is able to reload keystore.

ReloadableSslContext(String, String, String) - Constructor for class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

removeCachedStatus(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

Remove cached status for Flink resource.

removeCollectedMetrics(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

removeInfoFromCache(ResourceID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

removeInfoFromCache(ResourceID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

removeLastValidClusterHealthInfo(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

removeOperatorConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

removeParallelismOverrides(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

removeScalingHistory(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

removeSerializedState(KubernetesJobAutoScalerContext, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

requestJobResult(Configuration, JobID) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

requestJobResult(Configuration, JobID) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

rescheduleAfter(JobManagerDeploymentStatus, FlinkDeployment, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

resetSnapshotTriggers(AbstractFlinkResource<?, ?>, EventRecorder, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

RESOURCE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

RESOURCE_DELETION_PROPAGATION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

RESOURCE_NS - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

RESOURCE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

RESOURCE_USAGE_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

ResourceLifecycleMetricTracker - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle

Lifecycle state transition tracker for a single resource.

ResourceLifecycleMetricTracker(ResourceLifecycleState, Instant, Map<String, List<Histogram>>, Map<ResourceLifecycleState, List<Histogram>>) - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

resourceMetricGroups - Variable in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

RestartUnhealthyJob - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

restoreJob(FlinkResourceContext<CR>, SPEC, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

resubmitJob(FlinkResourceContext<CR>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

Rollback - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

run() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator

run() - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

runJar(JobSpec, JobID, JarUploadResponseBody, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

S

SAVEPOINT - org.apache.flink.kubernetes.operator.reconciler.SnapshotType

SAVEPOINT_ON_DELETION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

SavepointError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

SavepointFetchResult - Class in org.apache.flink.kubernetes.operator.observer

Result of a fetch savepoint operation.

SavepointFetchResult() - Constructor for class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult

savepointInProgress(JobStatus) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

SavepointTriggerRequestBody - Class in org.apache.flink.runtime.rest.messages.job.savepoints

RequestBody to trigger savepoints.

SavepointTriggerRequestBody(String, Boolean, SavepointFormatType, TriggerId) - Constructor for class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

scale(FlinkResourceContext<?>, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

scale(FlinkResourceContext<?>, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

scale(FlinkResourceContext<?>, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

Scaling - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

SCALING_HISTORY_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

SCALING_TRIGGERED - org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

scalingCompleted(FlinkResourceContext<?>) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

scalingCompleted(FlinkResourceContext<?>) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

scalingCompleted(FlinkResourceContext<?>) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

ScalingReport - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

SCOPE_NAMING_KUBERNETES_OPERATOR - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

SCOPE_NAMING_KUBERNETES_OPERATOR_RESOURCE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

SCOPE_NAMING_KUBERNETES_OPERATOR_RESOURCENS - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

SECTION_ADVANCED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

SECTION_DYNAMIC - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

SECTION_SYSTEM - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

serialize(ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

serializeEvaluatedMetrics(SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

serializeScalingHistory(Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

SESSION - org.apache.flink.kubernetes.operator.config.Mode

sessionClusterReady(Optional<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

sessionContext() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

SessionJobReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.sessionjob

The reconciler for the FlinkSessionJob.

SessionJobReconciler(EventRecorder, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

SessionObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment

The observer of the Mode.SESSION cluster.

SessionObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver

SessionReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Reconciler responsible for handling the session cluster lifecycle according to the desired and current states.

SessionReconciler(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

setGenerationAnnotation(Configuration, Long) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

setLastValidClusterHealthInfo(Map<String, String>, ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

setOwnerReference(CR, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

setRuntimeInfo(RuntimeInfo) - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

shouldDrain() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

shouldRecoverDeployment(Configuration, FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Checks whether the JobManager Kubernetes Deployment recovery logic should be initiated.

shouldTriggerSnapshot(AbstractFlinkResource<?, ?>, Configuration, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

Checks whether a snapshot should be triggered based on the current status and spec, and if yes, returns the correct SnapshotTriggerType.

SnapshotObserver<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,STATUS>,STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<?>> - Class in org.apache.flink.kubernetes.operator.observer

An observer of savepoint progress.

SnapshotObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.SnapshotObserver

SnapshotStatus - Enum in org.apache.flink.kubernetes.operator.utils

Enum encapsulating the lifecycle state of a Flink snapshot.

SnapshotType - Enum in org.apache.flink.kubernetes.operator.reconciler

This enumeration represents the types of state snapshots that can be taken in Flink.

SnapshotUtils - Class in org.apache.flink.kubernetes.operator.utils

Savepoint utilities.

SnapshotUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

SpecChanged - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

StandaloneFlinkService - Class in org.apache.flink.kubernetes.operator.service

Implementation of FlinkService submitting and interacting with Standalone Kubernetes Flink clusters and jobs.

StandaloneFlinkService(KubernetesClient, ArtifactManager, ExecutorService, FlinkOperatorConfiguration) - Constructor for class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

start() - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService

STATUS_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

statusCache - Variable in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

StatusConflictException - Exception in org.apache.flink.kubernetes.operator.exception

Exception for status updates.

StatusConflictException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.StatusConflictException

statusRecorder - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

StatusRecorder<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,STATUS>,STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<?>> - Class in org.apache.flink.kubernetes.operator.utils

Helper class for status management and updates.

StatusRecorder(MetricManager<CR>, BiConsumer<CR, STATUS>) - Constructor for class org.apache.flink.kubernetes.operator.utils.StatusRecorder

stop() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator

stop() - Method in class org.apache.flink.kubernetes.operator.health.HttpBootstrap

stop() - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService

StopWithSavepointRequestBody - Class in org.apache.flink.runtime.rest.messages.job.savepoints.stop

RequestBody for stopping a job with a savepoint.

StopWithSavepointRequestBody(String, Boolean, SavepointFormatType, TriggerId) - Constructor for class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

storeCollectedMetrics(KubernetesJobAutoScalerContext, SortedMap<Instant, CollectedMetrics>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

storeParallelismOverrides(KubernetesJobAutoScalerContext, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

storeScalingHistory(KubernetesJobAutoScalerContext, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

Submit - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

submitApplicationCluster(JobSpec, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

submitApplicationCluster(JobSpec, Configuration, boolean) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

submitClusterInternal(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

submitClusterInternal(Configuration, Mode) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

submitJobToSessionCluster(ObjectMeta, FlinkSessionJobSpec, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

submitJobToSessionCluster(ObjectMeta, FlinkSessionJobSpec, Configuration, String) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

submitSessionCluster(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

submitSessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

submitSessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

SUCCEEDED - org.apache.flink.kubernetes.operator.utils.SnapshotStatus

Snapshot is completed successfully.

Suspended - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

synchronizedCounter(Counter) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

SynchronizedCounter(Counter) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

SynchronizedHistogram(Histogram) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram

synchronizedMeterView(MeterView) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

SynchronizedMeterView(MeterView) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

T

timeControllerExecution(Metrics.ControllerExecution<T>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

to - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

toErrorStatusUpdateControl(FlinkResourceContext<R>, Exception, StatusRecorder<R, STATUS>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Update the resource error status and metrics when the operator encountered an exception during reconciliation.

toString() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult

toUpdateControl(FlinkOperatorConfiguration, R, R, boolean) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

TRACKED_TRANSITIONS - Static variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

Transition() - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

triggerCheckpoint(String, SnapshotTriggerType, CheckpointInfo, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

triggerCheckpoint(String, SnapshotTriggerType, CheckpointInfo, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEventOnce(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEventOnce(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEventWithInterval(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient, Duration) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEventWithLabels(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient, Duration, Predicate<Map<String, String>>, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerSavepoint(String, SnapshotTriggerType, SavepointInfo, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

triggerSavepoint(String, SnapshotTriggerType, SavepointInfo, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

triggerSnapshotIfNeeded(FlinkService, AbstractFlinkResource<?, ?>, Configuration, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

Triggers any pending manual or periodic snapshots and updates the status accordingly.

trimHistoryToMaxCmSize(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

U

UnknownJobException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal unrecognized job found.

UnknownJobException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException

UnknownJobException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException

UnknownJobException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException

UnsupportedFlinkVersion - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

update() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

update(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram

updateAfterScaleUp(AbstractFlinkResource<SPEC, ?>, Configuration, Clock, FlinkService.ScalingResult) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateDefaultConfig(Configuration) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

Update the base configuration for the operator.

updateErrorStatus(FlinkDeployment, Context<FlinkDeployment>, Exception) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

updateErrorStatus(FlinkSessionJob, Context<FlinkSessionJob>, Exception) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

updateFlinkResourceException(Throwable, R, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

updateForReconciliationError(FlinkResourceContext, Throwable) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateIngressRules(ObjectMeta, FlinkDeploymentSpec, Configuration, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils

updateLastReconciledSnapshotTriggerNonce(SnapshotInfo, AbstractFlinkResource<SPEC, ?>, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateReconciliationMetadata(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateStatusAfterClusterDeletion(FlinkDeploymentStatus) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC, ?>, Configuration, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Update status before deployment attempt of a new resource spec.

updateStatusForAlreadyUpgraded(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Updates status in cases where a previously successful deployment wasn't recorded for any reason.

updateStatusForDeployedSpec(AbstractFlinkResource<SPEC, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateStatusForDeployedSpec(AbstractFlinkResource<SPEC, ?>, Configuration, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Update status after successful deployment of a new resource spec.

updateStatusFromCache(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

Update the custom resource status based on the in-memory cached to ensure that any status updates that we made previously are always visible in the reconciliation loop.

updateVertexResources(RestClusterClient<String>, AbstractFlinkResource<?, ?>, Map<JobVertexID, JobVertexResourceRequirements>) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

uploadJar(ObjectMeta, FlinkSessionJobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

URL - Static variable in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

V

validateAutoScalerFlinkConfiguration(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator

validateDeployment(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator

validateDeployment(FlinkDeployment) - Method in interface org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator

Validate and return optional error.

validateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator

validateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in interface org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator

Validate and return optional error.

validateSupportedVersion(FlinkResourceContext<?>, EventRecorder) - Static method in class org.apache.flink.kubernetes.operator.utils.ValidatorUtils

ValidationError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

ValidationException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal validation failure.

ValidationException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException

ValidationException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException

ValidationException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException

ValidatorUtils - Class in org.apache.flink.kubernetes.operator.utils

Validator utilities.

ValidatorUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.ValidatorUtils

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.config.Mode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.reconciler.SnapshotType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.SnapshotStatus

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.kubernetes.operator.config.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.reconciler.SnapshotType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.utils.SnapshotStatus

Returns an array containing the constants of this enum type, in the order they are declared.

VERSION_CONF_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

W

waitForClusterShutdown(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

waitForClusterShutdown(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

Warning - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

Y

YAML_MAPPER - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

A B C D E F G H I J K L M N O P R S T U V W Y
All Classes All Packages