[FLINK-37320] [Observer] FINISHED finite streaming jobs incorrectly b…

…eing set to RECONCILING
apache · Feb 18, 2025 · 0a1dacd · 0a1dacd
1 parent 44dd679
commit 0a1dacd
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...apache/flink/kubernetes/operator/observer/deployment/AbstractFlinkDeploymentObserver.java b/...apache/flink/kubernetes/operator/observer/deployment/AbstractFlinkDeploymentObserver.java
@@ -152,7 +152,10 @@ protected void observeJmDeployment(FlinkResourceContext<FlinkDeployment> ctx) {
         }
 
         deploymentStatus.setJobManagerDeploymentStatus(JobManagerDeploymentStatus.MISSING);
-        deploymentStatus.getJobStatus().setState(JobStatus.RECONCILING);
+
+        if (!ReconciliationUtils.isJobInTerminalState(deploymentStatus)) {
+            deploymentStatus.getJobStatus().setState(JobStatus.RECONCILING);
+        }
 
         if (previousJmStatus != JobManagerDeploymentStatus.MISSING
                 && previousJmStatus != JobManagerDeploymentStatus.ERROR) {