[flink-kubernetes-operator] 01/02: [hotfix] Remove unnecessary client creation

[gyfora]

This is an automated email from the ASF dual-hosted git repository.

gyfora pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-kubernetes-operator.git

commit c41771a24c1db03b8d5513cc812ff3fb0ec43937
Author: Gyula Fora <g_f...@apple.com>
AuthorDate: Fri Feb 10 08:56:06 2023 +0100

    [hotfix] Remove unnecessary client creation
---
 .../flink/kubernetes/operator/service/AbstractFlinkService.java    | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java
index 97262daf..27578c04 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/AbstractFlinkService.java
@@ -640,12 +640,7 @@ public abstract class AbstractFlinkService implements 
FlinkService {
     @Override
     public PodList getJmPodList(FlinkDeployment deployment, Configuration 
conf) {
         final String namespace = 
conf.getString(KubernetesConfigOptions.NAMESPACE);
-        final String clusterId;
-        try (ClusterClient<String> clusterClient = getClusterClient(conf)) {
-            clusterId = clusterClient.getClusterId();
-        } catch (Exception ex) {
-            throw new RuntimeException(ex);
-        }
+        final String clusterId = 
conf.getString(KubernetesConfigOptions.CLUSTER_ID);
         return getJmPodList(namespace, clusterId);
     }