(amoro) branch master updated: [AMORO-3507] add table information to the log (#3509)

[jinsongzhou]

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

jinsongzhou 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 9488d8f2c [AMORO-3507] add table information to the log (#3509)
9488d8f2c is described below

commit 9488d8f2c9c6900ddc806c8cea25cb9d334b00bf
Author: LiJie20190102 <53458004+lijie20190...@users.noreply.github.com>
AuthorDate: Mon Apr 14 14:28:33 2025 +0800

    [AMORO-3507] add table information to the log (#3509)
    
    Improve:add table information to the log
---
 .../server/optimizing/maintainer/IcebergTableMaintainer.java   | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/IcebergTableMaintainer.java
 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/IcebergTableMaintainer.java
index 272e9f224..b4f59d706 100644
--- 
a/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/IcebergTableMaintainer.java
+++ 
b/amoro-ams/src/main/java/org/apache/amoro/server/optimizing/maintainer/IcebergTableMaintainer.java
@@ -189,7 +189,8 @@ public class IcebergTableMaintainer implements 
TableMaintainer {
 
   private void expireSnapshots(long olderThan, int minCount, Set<String> 
exclude) {
     LOG.debug(
-        "start expire snapshots older than {} and retain last {} snapshots, 
the exclude is {}",
+        "{}:start expire snapshots older than {} and retain last {} snapshots, 
the exclude is {}",
+        table.name(),
         olderThan,
         minCount,
         exclude);
@@ -229,7 +230,7 @@ public class IcebergTableMaintainer implements 
TableMaintainer {
             TableFileUtil.deleteEmptyDirectory(fileIO(), parent, exclude);
           } catch (Exception e) {
             // Ignore exceptions to remove as many directories as possible
-            LOG.warn("Fail to delete empty directory {}", parent, e);
+            LOG.warn("{}:fail to delete empty directory {}", table.name(), 
parent, e);
           }
         });
 
@@ -471,7 +472,10 @@ public class IcebergTableMaintainer implements 
TableMaintainer {
           CommitMetaProducer.CLEAN_DANGLING_DELETE.name());
       rewriteFiles.commit();
     } catch (ValidationException e) {
-      LOG.warn("Iceberg RewriteFiles commit failed on clear 
danglingDeleteFiles, but ignore", e);
+      LOG.warn(
+          "{}:iceberg rewriteFiles commit failed on clear danglingDeleteFiles, 
but ignore",
+          table.name(),
+          e);
       return 0;
     }
     return danglingDeleteFiles.size();