Class StandaloneFlinkService

    • Constructor Detail

      • StandaloneFlinkService

        public StandaloneFlinkService​(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient,
                                      FlinkConfigManager configManager)
    • Method Detail

      • deployApplicationCluster

        protected void deployApplicationCluster​(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​(FlinkDeployment deployment,
                              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
      • createNamespacedKubeClient

        @VisibleForTesting
        protected 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)
        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
      • scale

        public boolean scale​(io.fabric8.kubernetes.api.model.ObjectMeta meta,
                             JobSpec jobSpec,
                             org.apache.flink.configuration.Configuration conf)