(amoro) branch master updated: [AMORO-3194]improvement: optimize plan log print (#3212)

[taowang]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 7081bbcfe [AMORO-3194]improvement: optimize plan log print (#3212)
7081bbcfe is described below

commit 7081bbcfe17798fc1def5956f4aa4e67db6eda38
Author: Wang Tao <wtrunw...@gmail.com>
AuthorDate: Fri Sep 20 15:17:31 2024 +0800

    [AMORO-3194]improvement: optimize plan log print (#3212)
    
    improvement: optimize log print
    
    Co-authored-by: 王涛 <wangtao@HIH-L-10114.local>
---
 .../org/apache/amoro/server/optimizing/OptimizingQueue.java  | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java
 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java
index bd1e5023a..dd192c129 100644
--- 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java
+++ 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/OptimizingQueue.java
@@ -235,12 +235,20 @@ public class OptimizingQueue extends PersistentBase {
                 planningTables.remove(tableRuntime.getTableIdentifier());
                 if (process != null) {
                   tableQueue.offer(process);
+                  String skipIds =
+                      skipTables.stream()
+                          .map(ServerTableIdentifier::getId)
+                          .sorted()
+                          .map(item -> item + "")
+                          .collect(Collectors.joining(","));
                   LOG.info(
-                      "Completed planning on table {} with {} tasks with a 
total cost of {} ms, skipping tables {}",
+                      "Completed planning on table {} with {} tasks with a 
total cost of {} ms, skipping {} tables,"
+                          + " id list:{}",
                       tableRuntime.getTableIdentifier(),
                       process.getTaskMap().size(),
                       currentTime - startTime,
-                      skipTables);
+                      skipTables.size(),
+                      skipIds);
                 } else if (throwable == null) {
                   LOG.info(
                       "Skip planning table {} with a total cost of {} ms.",