(incubator-paimon) 22/46: [core] Add log for migrate (#2403)

[lz...@apache.org]

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

lzljs3620320 pushed a commit to branch release-0.6
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git

commit 00ebe38a46b1f1db0646cfe16ffd168d82c70e3e
Author: YeJunHao <41...@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;
     }