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)
