Fix the issue where the HA files are not cleaned up when the Flink jo…

…b stops, causing two identical jobs to start the next time a new job is launched. (#4029)
apache · Sep 4, 2024 · e886549 · e886549
1 parent 5ff2098
commit e886549
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/...ain/scala/org/apache/streampark/flink/client/impl/KubernetesNativeApplicationClient.scala b/...ain/scala/org/apache/streampark/flink/client/impl/KubernetesNativeApplicationClient.scala
@@ -82,7 +82,6 @@ object KubernetesNativeApplicationClient extends KubernetesNativeClientTrait {
       flinkConf,
       (jobId, client) => {
         val resp = super.cancelJob(cancelRequest, jobId, client)
-        client.shutDownCluster()
         CancelResponse(resp)
       }
     )