Skip to content

Commit f3db414

Browse files
stevenpyzhangmorhidi
authored andcommitted
[FLINK-30287] Delete job manager deployment first when cleaning up standalone cluster
1 parent 41b9f4f commit f3db414

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/StandaloneFlinkService.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -134,20 +134,20 @@ protected void deleteClusterInternal(ObjectMeta meta, boolean deleteHaConfigmaps
134134
final String clusterId = meta.getName();
135135
final String namespace = meta.getNamespace();
136136

137-
LOG.info("Deleting Flink Standalone cluster TM resources");
137+
LOG.info("Deleting Flink Standalone cluster JM resources");
138138
kubernetesClient
139139
.apps()
140140
.deployments()
141141
.inNamespace(namespace)
142-
.withName(StandaloneKubernetesUtils.getTaskManagerDeploymentName(clusterId))
142+
.withName(StandaloneKubernetesUtils.getJobManagerDeploymentName(clusterId))
143143
.delete();
144144

145-
LOG.info("Deleting Flink Standalone cluster JM resources");
145+
LOG.info("Deleting Flink Standalone cluster TM resources");
146146
kubernetesClient
147147
.apps()
148148
.deployments()
149149
.inNamespace(namespace)
150-
.withName(StandaloneKubernetesUtils.getJobManagerDeploymentName(clusterId))
150+
.withName(StandaloneKubernetesUtils.getTaskManagerDeploymentName(clusterId))
151151
.delete();
152152

153153
if (deleteHaConfigmaps) {

0 commit comments

Comments
 (0)