[iceberg] branch master updated: Hive: Log new metadata location in commit (#4681)

[bl...@apache.org]

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

blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new 30b31a238 Hive: Log new metadata location in commit (#4681)
30b31a238 is described below

commit 30b31a238d8783faaeefdb5934ca398c28cb4d66
Author: Yufei Gu <yu...@apache.org>
AuthorDate: Wed May 4 08:45:34 2022 -0700

    Hive: Log new metadata location in commit (#4681)
---
 core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java | 2 ++
 .../src/main/java/org/apache/iceberg/hive/HiveTableOperations.java      | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java b/core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java
index c68ee929d..f2347a9b9 100644
--- a/core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java
+++ b/core/src/main/java/org/apache/iceberg/hadoop/HadoopTableOperations.java
@@ -157,6 +157,8 @@ public class HadoopTableOperations implements TableOperations {
     // this rename operation is the atomic commit operation
     renameToFinal(fs, tempMetadataFile, finalMetadataFile, nextVersion);
 
+    LOG.info("Committed a new metadata file {}", finalMetadataFile);
+
     // update the best-effort version pointer
     writeVersionHint(nextVersion);
 
diff --git a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java
index 1303fd15d..8b483843a 100644
--- a/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java
+++ b/hive-metastore/src/main/java/org/apache/iceberg/hive/HiveTableOperations.java
@@ -311,6 +311,8 @@ public class HiveTableOperations extends BaseMetastoreTableOperations {
     } finally {
       cleanupMetadataAndUnlock(commitStatus, newMetadataLocation, lockId, tableLevelMutex);
     }
+
+    LOG.info("Committed to table {} with the new metadata location {}", fullName, newMetadataLocation);
   }
 
   @VisibleForTesting