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 c68ee929deea..f2347a9b932f 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 void commit(TableMetadata base, TableMetadata metadata) { // 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 1303fd15d89b..8b483843a8cb 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 @@ protected void doCommit(TableMetadata base, TableMetadata metadata) { } finally { cleanupMetadataAndUnlock(commitStatus, newMetadataLocation, lockId, tableLevelMutex); } + + LOG.info("Committed to table {} with the new metadata location {}", fullName, newMetadataLocation); } @VisibleForTesting