(amoro) branch master updated: (hotfix) enhance log for iceberg table maintainer (#3543)

[klion26]

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

klion26 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 e3a7dff0d (hotfix) enhance log for iceberg table maintainer (#3543)
e3a7dff0d is described below

commit e3a7dff0d945601400a9d0b6d83b79abc526787b
Author: Congxian Qiu <qcx978132...@gmail.com>
AuthorDate: Wed Apr 30 16:31:02 2025 +0800

    (hotfix) enhance log for iceberg table maintainer (#3543)
    
    This commit enhances the log by adding the expiration time, making the 
expiration time
    more intuitive for the user
---
 .../server/optimizing/maintainer/IcebergTableMaintainer.java   | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 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 5adcff3e0..03e7fa326 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
@@ -321,13 +321,19 @@ public class IcebergTableMaintainer implements 
TableMaintainer {
     // so acquire in advance
     // to prevent repeated acquisition
     Set<String> validFiles = orphanFileCleanNeedToExcludeFiles();
-    LOG.info("Starting cleaning orphan content files for table {}", 
table.name());
+    LOG.info(
+        "Starting cleaning orphan content files for table {} before {}",
+        table.name(),
+        Instant.ofEpochMilli(lastTime));
     clearInternalTableContentsFiles(lastTime, validFiles, 
orphanFilesCleaningMetrics);
   }
 
   protected void cleanMetadata(
       long lastTime, TableOrphanFilesCleaningMetrics 
orphanFilesCleaningMetrics) {
-    LOG.info("Starting cleaning metadata files for table {}", table.name());
+    LOG.info(
+        "Starting cleaning metadata files for table {} before {}",
+        table.name(),
+        Instant.ofEpochMilli(lastTime));
     clearInternalTableMetadata(lastTime, orphanFilesCleaningMetrics);
   }