fix

askwang · Sep 14, 2024 · cadc311 · cadc311
1 parent 2c45ac0
commit cadc311
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/CompactProcedure.java b/...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;
         }