[flink-kubernetes-operator] branch main updated: [FLINK-30287] Delete job manager deployment first when cleaning up standalone cluster

[morhidi]

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

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


The following commit(s) were added to refs/heads/main by this push:
     new f3db414f [FLINK-30287] Delete job manager deployment first when 
cleaning up standalone cluster
f3db414f is described below

commit f3db414ff2673d69aa113d63c996912fb9d57bc4
Author: Steven Zhang <stev...@confluent.io>
AuthorDate: Fri Dec 2 11:28:23 2022 -0800

    [FLINK-30287] Delete job manager deployment first when cleaning up 
standalone cluster
---
 .../flink/kubernetes/operator/service/StandaloneFlinkService.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java
index a9a5c21f..ad3e190e 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java
@@ -134,20 +134,20 @@ public class StandaloneFlinkService extends 
AbstractFlinkService {
         final String clusterId = meta.getName();
         final String namespace = meta.getNamespace();
 
-        LOG.info("Deleting Flink Standalone cluster TM resources");
+        LOG.info("Deleting Flink Standalone cluster JM resources");
         kubernetesClient
                 .apps()
                 .deployments()
                 .inNamespace(namespace)
-                
.withName(StandaloneKubernetesUtils.getTaskManagerDeploymentName(clusterId))
+                
.withName(StandaloneKubernetesUtils.getJobManagerDeploymentName(clusterId))
                 .delete();
 
-        LOG.info("Deleting Flink Standalone cluster JM resources");
+        LOG.info("Deleting Flink Standalone cluster TM resources");
         kubernetesClient
                 .apps()
                 .deployments()
                 .inNamespace(namespace)
-                
.withName(StandaloneKubernetesUtils.getJobManagerDeploymentName(clusterId))
+                
.withName(StandaloneKubernetesUtils.getTaskManagerDeploymentName(clusterId))
                 .delete();
 
         if (deleteHaConfigmaps) {