Package org.apache.flink.kubernetes.operator.service

Class StandaloneFlinkService

java.lang.Object

org.apache.flink.kubernetes.operator.service.AbstractFlinkService

org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

All Implemented Interfaces:

FlinkService

public class StandaloneFlinkService
extends AbstractFlinkService

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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.kubernetes.operator.service.FlinkService

FlinkService.ScalingResult

Field Summary

Fields inherited from class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

artifactManager, executorService, FIELD_NAME_TOTAL_CPU, FIELD_NAME_TOTAL_MEMORY, kubernetesClient, operatorConfig

Constructor Summary

Constructors

Constructor	Description
StandaloneFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, ArtifactManager artifactManager, java.util.concurrent.ExecutorService executorService, FlinkOperatorConfiguration operatorConfig)

Method Summary

Modifier and Type	Method	Description
void	cancelJob(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment, org.apache.flink.kubernetes.operator.api.spec.UpgradeMode upgradeMode, org.apache.flink.configuration.Configuration conf)
protected org.apache.flink.kubernetes.operator.kubeclient.FlinkStandaloneKubeClient	createNamespacedKubeClient(org.apache.flink.configuration.Configuration configuration)
protected void	deleteClusterInternal(io.fabric8.kubernetes.api.model.ObjectMeta meta, org.apache.flink.configuration.Configuration conf, boolean deleteHaData, io.fabric8.kubernetes.api.model.DeletionPropagation deletionPropagation)	Delete Flink kubernetes cluster by deleting the kubernetes resources directly.
protected void	deployApplicationCluster(org.apache.flink.kubernetes.operator.api.spec.JobSpec jobSpec, org.apache.flink.configuration.Configuration conf)
protected io.fabric8.kubernetes.api.model.PodList	getJmPodList(java.lang.String namespace, java.lang.String clusterId)
protected io.fabric8.kubernetes.api.model.PodList	getTmPodList(java.lang.String namespace, java.lang.String clusterId)
FlinkService.ScalingResult	scale(FlinkResourceContext<?> ctx, org.apache.flink.configuration.Configuration deployConfig)
boolean	scalingCompleted(FlinkResourceContext<?> resourceContext)
protected void	submitClusterInternal(org.apache.flink.configuration.Configuration conf, Mode mode)
void	submitSessionCluster(org.apache.flink.configuration.Configuration conf)

Methods inherited from class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

cancelJob, cancelSessionJob, deleteClusterDeployment, deleteHAData, disposeSavepoint, fetchCheckpointInfo, fetchSavepointInfo, getCheckpointInfo, getClusterClient, getClusterInfo, getEffectiveStatus, getJmPodList, getJobDetailsInfo, getKubernetesClient, getLastCheckpoint, getMetrics, getRestClient, isHaMetadataAvailable, isJobManagerPortReady, listJobs, removeOperatorConfigs, requestJobResult, runJar, submitApplicationCluster, submitJobToSessionCluster, triggerCheckpoint, triggerSavepoint, updateStatusAfterClusterDeletion, uploadJar, waitForClusterShutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StandaloneFlinkService

public StandaloneFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
                              ArtifactManager artifactManager,
                              java.util.concurrent.ExecutorService executorService,
                              FlinkOperatorConfiguration operatorConfig)

Method Detail

deployApplicationCluster

protected void deployApplicationCluster(org.apache.flink.kubernetes.operator.api.spec.JobSpec jobSpec,
                                        org.apache.flink.configuration.Configuration conf)
                                 throws java.lang.Exception

Specified by:

deployApplicationCluster in class AbstractFlinkService

Throws:

java.lang.Exception

submitSessionCluster

public void submitSessionCluster(org.apache.flink.configuration.Configuration conf)
                          throws java.lang.Exception

Throws:

java.lang.Exception

cancelJob

public void cancelJob(org.apache.flink.kubernetes.operator.api.FlinkDeployment deployment,
                      org.apache.flink.kubernetes.operator.api.spec.UpgradeMode upgradeMode,
                      org.apache.flink.configuration.Configuration conf)
               throws java.lang.Exception

Throws:

java.lang.Exception

getJmPodList

protected io.fabric8.kubernetes.api.model.PodList getJmPodList(java.lang.String namespace,
                                                               java.lang.String clusterId)

Specified by:

getJmPodList in class AbstractFlinkService

getTmPodList

protected io.fabric8.kubernetes.api.model.PodList getTmPodList(java.lang.String namespace,
                                                               java.lang.String clusterId)

Specified by:

getTmPodList in class AbstractFlinkService

createNamespacedKubeClient

@VisibleForTesting
protected org.apache.flink.kubernetes.operator.kubeclient.FlinkStandaloneKubeClient createNamespacedKubeClient(org.apache.flink.configuration.Configuration configuration)

submitClusterInternal

protected void submitClusterInternal(org.apache.flink.configuration.Configuration conf,
                                     Mode mode)
                              throws org.apache.flink.client.deployment.ClusterDeploymentException

Throws:

org.apache.flink.client.deployment.ClusterDeploymentException

deleteClusterInternal

protected void deleteClusterInternal(io.fabric8.kubernetes.api.model.ObjectMeta meta,
                                     org.apache.flink.configuration.Configuration conf,
                                     boolean deleteHaData,
                                     io.fabric8.kubernetes.api.model.DeletionPropagation deletionPropagation)

Description copied from class: AbstractFlinkService

Delete Flink kubernetes cluster by deleting the kubernetes resources directly. Optionally allows deleting the native kubernetes HA resources as well.

Specified by:

deleteClusterInternal in class AbstractFlinkService

Parameters:

meta - ObjectMeta of the deployment

conf - Configuration of the Flink application

deleteHaData - Flag to indicate whether k8s or Zookeeper HA metadata should be removed as well

deletionPropagation - Resource deletion propagation policy

scale

public FlinkService.ScalingResult scale(FlinkResourceContext<?> ctx,
                                        org.apache.flink.configuration.Configuration deployConfig)

scalingCompleted

public boolean scalingCompleted(FlinkResourceContext<?> resourceContext)