Trigger immediate reconcile after driver status change

jiangzho · jiangzho · commit 8ad7b9a26343 · 2025-09-25T13:44:40.000-07:00
diff --git a/spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/reconcilesteps/AppReconcileStep.java b/spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/reconcilesteps/AppReconcileStep.java
@@ -19,7 +19,6 @@
 
 package org.apache.spark.k8s.operator.reconciler.reconcilesteps;
 
-import static org.apache.spark.k8s.operator.reconciler.ReconcileProgress.completeAndDefaultRequeue;
 import static org.apache.spark.k8s.operator.reconciler.ReconcileProgress.completeAndImmediateRequeue;
 import static org.apache.spark.k8s.operator.reconciler.ReconcileProgress.proceed;
 import static org.apache.spark.k8s.operator.utils.SparkAppStatusUtils.driverUnexpectedRemoved;
@@ -81,7 +80,7 @@ protected ReconcileProgress observeDriver(
           currentStatus = currentStatus.appendNewState(state);
         }
         return attemptStatusUpdate(
-            context, statusRecorder, currentStatus, completeAndDefaultRequeue());
+            context, statusRecorder, currentStatus, completeAndImmediateRequeue());
       }
     } else {
       ApplicationStatus updatedStatus = currentStatus.appendNewState(driverUnexpectedRemoved());

Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,6 @@`
`19`	`19`
`20`	`20`	`package org.apache.spark.k8s.operator.reconciler.reconcilesteps;`
`21`	`21`
`22`		`-import static org.apache.spark.k8s.operator.reconciler.ReconcileProgress.completeAndDefaultRequeue;`
`23`	`22`	`import static org.apache.spark.k8s.operator.reconciler.ReconcileProgress.completeAndImmediateRequeue;`
`24`	`23`	`import static org.apache.spark.k8s.operator.reconciler.ReconcileProgress.proceed;`
`25`	`24`	`import static org.apache.spark.k8s.operator.utils.SparkAppStatusUtils.driverUnexpectedRemoved;`
`@@ -81,7 +80,7 @@ protected ReconcileProgress observeDriver(`
`81`	`80`	`currentStatus = currentStatus.appendNewState(state);`
`82`	`81`	`}`
`83`	`82`	`return attemptStatusUpdate(`
`84`		`- context, statusRecorder, currentStatus, completeAndDefaultRequeue());`
	`83`	`+ context, statusRecorder, currentStatus, completeAndImmediateRequeue());`
`85`	`84`	`}`
`86`	`85`	`} else {`
`87`	`86`	`ApplicationStatus updatedStatus = currentStatus.appendNewState(driverUnexpectedRemoved());`