It should wait for spark pods being deleted in SUSPENDED reconciliati…

…on loop. Signed-off-by: Shingo Omura <[email protected]>
kubeflow · Jan 20, 2025 · 7f87e65 · 7f87e65
1 parent 4c5b807
commit 7f87e65
Showing 1 changed file with 4 additions and 0 deletions.
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