(paimon) branch master updated: [core] Add log to partition expire

[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 6c51e7580 [core] Add log to partition expire
6c51e7580 is described below

commit 6c51e75806f338403c71a2f3f3e711c2b2150627
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Thu Apr 25 14:55:27 2024 +0800

    [core] Add log to partition expire
---
 .../main/java/org/apache/paimon/operation/PartitionExpire.java   | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java 
b/paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java
index 2b31daa80..895121ac4 100644
--- a/paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java
+++ b/paimon-core/src/main/java/org/apache/paimon/operation/PartitionExpire.java
@@ -28,6 +28,9 @@ import org.apache.paimon.partition.PartitionTimeExtractor;
 import org.apache.paimon.types.RowType;
 import org.apache.paimon.utils.RowDataToObjectArrayConverter;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import java.time.Duration;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
@@ -40,6 +43,8 @@ import java.util.stream.Collectors;
 /** Expire partitions. */
 public class PartitionExpire {
 
+    private static final Logger LOG = 
LoggerFactory.getLogger(PartitionExpire.class);
+
     private final List<String> partitionKeys;
     private final RowDataToObjectArrayConverter toObjectArrayConverter;
     private final Duration expirationTime;
@@ -94,7 +99,9 @@ public class PartitionExpire {
         List<Map<String, String>> expired = new ArrayList<>();
         for (BinaryRow partition : readPartitions(expireDateTime)) {
             Object[] array = toObjectArrayConverter.convert(partition);
-            expired.add(toPartitionString(array));
+            Map<String, String> partString = toPartitionString(array);
+            expired.add(partString);
+            LOG.info("Expire Partition: " + partition);
         }
         if (expired.size() > 0) {
             commit.dropPartitions(expired, commitIdentifier);