From ca5b09e7d544ad6a79e8a24eddec1560cb4ccc1f Mon Sep 17 00:00:00 2001 From: Dongjoon Hyun Date: Wed, 2 Jul 2025 23:05:02 -0700 Subject: [PATCH] [SPARK-52667] Improve `SparkAppReconciler` to show app names during cleaning up --- .../spark/k8s/operator/reconciler/SparkAppReconciler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppReconciler.java b/spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppReconciler.java index c3b42e72..bae0e5b1 100644 --- a/spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppReconciler.java +++ b/spark-operator/src/main/java/org/apache/spark/k8s/operator/reconciler/SparkAppReconciler.java @@ -183,7 +183,7 @@ public DeleteControl cleanup( LoggingUtils.TrackedMDC trackedMDC = new LoggingUtils.TrackedMDC(); try { trackedMDC.set(sparkApplication); - log.info("Cleaning up resources for SparkApp."); + log.info("Cleaning up resources for SparkApp:" + sparkApplication.getMetadata().getName()); SparkAppContext ctx = new SparkAppContext(sparkApplication, context, submissionWorker); List cleanupSteps = new ArrayList<>(); cleanupSteps.add(new AppValidateStep()); @@ -200,7 +200,7 @@ public DeleteControl cleanup( } } } finally { - log.info("Cleanup completed"); + log.debug("Cleanup completed"); trackedMDC.reset(); } sparkAppStatusRecorder.removeCachedStatus(sparkApplication);