[jira] [Created] (FLINK-26344) waitForClusterShutdown does not work correctly in Flink Kubernetes operator

["Yang Wang (Jira)" <ji...@apache.org>]

Yang Wang created FLINK-26344:
---------------------------------

             Summary: waitForClusterShutdown does not work correctly in Flink Kubernetes operator 
                 Key: FLINK-26344
                 URL: https://issues.apache.org/jira/browse/FLINK-26344
             Project: Flink
          Issue Type: Bug
          Components: Kubernetes Operator
            Reporter: Yang Wang


 
{code:java}
Fabric8FlinkKubeClient flinkKubeClient =
        new Fabric8FlinkKubeClient(
                conf, kubernetesClient, Executors.newSingleThreadExecutor()); {code}
 

{{Fabric8FlinkKubeClient}} expects an namespaced Kubernetes client. If we create FlinkDeployment is a different namespace with K8s operator, {{FlinkService#waitForClusterShutdown()}} will not work.

 

We could directly use the Kubernetes client to do the existence check for deployment.
{code:java}
kubernetesClient.apps().deployments().inNamespace(namespace).withName(clusterId).get() == null{code}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)