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
commit aced6a43b66aaeb28ec2212bf2746e814f3e293a Author: Gyula Fora <[email protected]> AuthorDate: Wed Mar 1 09:01:58 2023 +0100 [hotfix] Add missing waitforshutdown after cluster deletion --- .../operator/reconciler/deployment/ApplicationReconciler.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) 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 67396671..f68960f9 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 @@ -224,12 +224,11 @@ public class ApplicationReconciler @Override protected void cleanupAfterFailedJob(FlinkResourceContext<FlinkDeployment> ctx) { // The job has already stopped. Delete the deployment and we are ready. - ctx.getFlinkService() - .deleteClusterDeployment( - ctx.getResource().getMetadata(), - ctx.getResource().getStatus(), - ctx.getDeployConfig(ctx.getResource().getSpec()), - false); + var flinkService = ctx.getFlinkService(); + var conf = ctx.getDeployConfig(ctx.getResource().getSpec()); + flinkService.deleteClusterDeployment( + ctx.getResource().getMetadata(), ctx.getResource().getStatus(), conf, false); + flinkService.waitForClusterShutdown(conf); } // Workaround for https://issues.apache.org/jira/browse/FLINK-27569
