From cadc31153d09995caf96916b3b3942de8a0eecd0 Mon Sep 17 00:00:00 2001
From: Askwang <135721692+Askwang@users.noreply.github.com>
Date: Sat, 14 Sep 2024 09:51:25 +0800
Subject: [PATCH] fix

---
 .../org/apache/paimon/spark/procedure/CompactProcedure.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java
index 964fca5aa80c..5b5f4e33c2ee 100644
--- a/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java
+++ b/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java
@@ -280,6 +280,7 @@ private void compactAwareBucketTable(
                         .collect(Collectors.toList());
 
         if (partitionBuckets.isEmpty()) {
+            LOG.info("Partition bucket is empty, no compact job to execute.");
             return;
         }
 
@@ -360,7 +361,7 @@ private void compactUnAwareBucketTable(
                             .collect(Collectors.toList());
         }
         if (compactionTasks.isEmpty()) {
-            System.out.println("compaction task is empty.");
+            LOG.info("Task plan is empty, no compact job to execute.");
             return;
         }