(paimon) branch master updated: [hive] Update columns when committing Iceberg metadata (#5691)

[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 b4be1f1bac [hive] Update columns when committing Iceberg metadata 
(#5691)
b4be1f1bac is described below

commit b4be1f1bacf7af5c2111008cbfbacf439df0214e
Author: Sina Siadat <s...@yelp.com>
AuthorDate: Thu Jun 5 02:57:30 2025 +0100

    [hive] Update columns when committing Iceberg metadata (#5691)
---
 .../org/apache/paimon/iceberg/IcebergHiveMetadataCommitter.java     | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/iceberg/IcebergHiveMetadataCommitter.java
 
b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/iceberg/IcebergHiveMetadataCommitter.java
index faba89fffd..754da1e6a1 100644
--- 
a/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/iceberg/IcebergHiveMetadataCommitter.java
+++ 
b/paimon-hive/paimon-hive-catalog/src/main/java/org/apache/paimon/iceberg/IcebergHiveMetadataCommitter.java
@@ -147,6 +147,12 @@ public class IcebergHiveMetadataCommitter implements 
IcebergMetadataCommitter {
                     .put("previous_metadata_location", 
baseMetadataPath.toString());
         }
 
+        StorageDescriptor sd = hiveTable.getSd();
+        sd.setCols(
+                table.schema().fields().stream()
+                        .map(this::convertToFieldSchema)
+                        .collect(Collectors.toList()));
+
         Options options = new Options(table.options());
         boolean skipAWSGlueArchive = 
options.get(IcebergOptions.GLUE_SKIP_ARCHIVE);
         EnvironmentContext environmentContext = new EnvironmentContext();