It should wait for spark pods being deleted in SUSPENDED reconciliation loop.

everpeace · everpeace · commit 7f87e6564ab4 · 2025-01-20T19:45:44.000+09:00
Signed-off-by: Shingo Omura &lt;everpeace@gmail.com&gt;
diff --git a/internal/controller/sparkapplication/controller.go b/internal/controller/sparkapplication/controller.go
@@ -723,6 +723,10 @@ func (r *Reconciler) reconcileSuspendedSparkApplication(ctx context.Context, req
 						State: v1beta2.ApplicationStateResuming,
 					}
 				}
+			} else {
+				err := fmt.Errorf("resources associated with SparkApplication still exist: %s/%s", app.Namespace, app.Name)
+				logger.Error(err, "Failed to confirm being deleted resources associated with SparkApplication", "name", app.Name, "namespace", app.Namespace, "state", app.Status.AppState.State)
+				return err
 			}
 			if err := r.updateSparkApplicationStatus(ctx, app); err != nil {
 				return err

Original file line number	Diff line number	Diff line change
`@@ -723,6 +723,10 @@ func (r *Reconciler) reconcileSuspendedSparkApplication(ctx context.Context, req`
`723`	`723`	`State: v1beta2.ApplicationStateResuming,`
`724`	`724`	`}`
`725`	`725`	`}`
	`726`	`+ } else {`
	`727`	`+ err := fmt.Errorf("resources associated with SparkApplication still exist: %s/%s", app.Namespace, app.Name)`
	`728`	`+ logger.Error(err, "Failed to confirm being deleted resources associated with SparkApplication", "name", app.Name, "namespace", app.Namespace, "state", app.Status.AppState.State)`
	`729`	`+ return err`
`726`	`730`	`}`
`727`	`731`	`if err := r.updateSparkApplicationStatus(ctx, app); err != nil {`
`728`	`732`	`return err`