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);