[flink-kubernetes-operator] branch main updated: [hotfix] Delete HA data when deleting terminal cluster

[gyfora]

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

gyfora 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 ef7e891  [hotfix] Delete HA data when deleting terminal cluster
ef7e891 is described below

commit ef7e891af67a8c5a1c94d38a33ccc195fad682ff
Author: Gyula Fora <g_f...@apple.com>
AuthorDate: Wed May 25 20:13:19 2022 -0700

    [hotfix] Delete HA data when deleting terminal cluster
---
 .../operator/reconciler/deployment/ApplicationReconciler.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java
 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java
index 9b2f841..442206f 100644
--- 
a/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java
+++ 
b/flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/deployment/ApplicationReconciler.java
@@ -271,7 +271,7 @@ public class ApplicationReconciler extends 
AbstractDeploymentReconciler {
                 throw new RuntimeException("This indicates a bug...");
             }
             LOG.info("Deleting deployment with terminated application before 
new deployment");
-            flinkService.deleteClusterDeployment(meta, status, false);
+            flinkService.deleteClusterDeployment(meta, status, true);
             FlinkUtils.waitForClusterShutdown(
                     kubernetesClient,
                     deployConfig,