(paimon) branch master updated: [spark] Fix compact unreasonable log info (#4187)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new e6e15405b [spark] Fix compact unreasonable log info (#4187)
e6e15405b is described below

commit e6e15405be89d82b7945a35b1aff6a669a0375b5
Author: askwang <135721692+askw...@users.noreply.github.com>
AuthorDate: Thu Sep 19 10:00:37 2024 +0800

    [spark] Fix compact unreasonable log info (#4187)
---
 .../main/java/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 964fca5aa..5b5f4e33c 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 @@ public class CompactProcedure extends BaseProcedure {
                         .collect(Collectors.toList());
 
         if (partitionBuckets.isEmpty()) {
+            LOG.info("Partition bucket is empty, no compact job to execute.");
             return;
         }
 
@@ -360,7 +361,7 @@ public class CompactProcedure extends BaseProcedure {
                             .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;
         }