(incubator-paimon) branch master updated: [core] Add log for migrate (#2403)

[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/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 74f3a2a94 [core] Add log for migrate (#2403)
74f3a2a94 is described below

commit 74f3a2a94d93a931d18b3e16f187dd0c915cd1c8
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Tue Nov 28 14:16:00 2023 +0800

    [core] Add log for migrate (#2403)
---
 .../src/main/java/org/apache/paimon/migrate/FileMetaUtils.java      | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java 
b/paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java
index c39a68001..57b4bf8a2 100644
--- a/paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java
+++ b/paimon-core/src/main/java/org/apache/paimon/migrate/FileMetaUtils.java
@@ -43,6 +43,9 @@ import org.apache.paimon.utils.Pair;
 import org.apache.paimon.utils.StatsCollectorFactories;
 import org.apache.paimon.utils.TypeUtils;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import java.io.IOException;
 import java.util.Arrays;
 import java.util.Collections;
@@ -54,6 +57,8 @@ import java.util.stream.Collectors;
 /** To construct file meta data for external files. */
 public class FileMetaUtils {
 
+    private static final Logger LOG = 
LoggerFactory.getLogger(FileMetaUtils.class);
+
     public static List<DataFileMeta> construct(
             FileIO fileIO,
             String format,
@@ -135,6 +140,7 @@ public class FileMetaUtils {
         String newFileName = fileName.endsWith(subfix) ? fileName : fileName + 
"." + format;
         Path newPath = new Path(newDir, newFileName);
         rollback.put(newPath, originPath);
+        LOG.info("Migration: rename file from " + originPath + " to " + 
newPath);
         fileIO.rename(originPath, newPath);
         return newPath;
     }