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