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

…en resubmitting the task. (#3969) Co-authored-by: yuhang2.zhang <[email protected]>
DataLinkDC · Nov 27, 2024 · e9061cb · e9061cb
1 parent 697ac66
commit e9061cb
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);