From c07624811c06608b7eb03ee9f1b26d0ffacd1bc1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E6=B6=9B?= Date: Fri, 20 Sep 2024 10:34:12 +0800 Subject: [PATCH] improvement: optimize log print --- .../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 bd1e5023a0..dd192c1298 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 @@ private void triggerAsyncPlanning( 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.",