[Optimization][dinky-getaway] Delete the previously failed cluster wh…

…en resubmitting the task. (DataLinkDC#3969) Co-authored-by: yuhang2.zhang <[email protected]>
Zzm0809 · Dec 7, 2024 · 20a44c4 · 20a44c4
1 parent 1d08cf3
commit 20a44c4
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ky-client-1.18/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java b/...ky-client-1.18/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java
@@ -171,7 +171,8 @@ public ClusterClientProvider<String> deployApplicationCluster(
             throws ClusterDeploymentException {
         if (client.getService(ExternalServiceDecorator.getExternalServiceName(clusterId))
                 .isPresent()) {
-            throw new ClusterDeploymentException("The Flink cluster " + clusterId + " already exists.");
+            client.stopAndCleanupCluster(clusterId);
+            LOG.warn("The Flink cluster {} already exists, automatically stopAndCleanupCluster.", clusterId);
         }
 
         checkNotNull(clusterSpecification);