(paimon) branch master updated: [hive] Hive metastore support create table with blob (#6383)

[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 04c7b1e4d9 [hive] Hive metastore support create table with blob (#6383)
04c7b1e4d9 is described below

commit 04c7b1e4d9a692abd9cdc1589acbb4166b485dbf
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Sat Oct 11 15:42:07 2025 +0800

    [hive] Hive metastore support create table with blob (#6383)
---
 .../org/apache/paimon/hive/HiveCatalogTest.java     | 21 +++++++++++++++++++++
 .../java/org/apache/paimon/hive/HiveTypeUtils.java  |  6 ++++++
 2 files changed, 27 insertions(+)

diff --git 
a/paimon-hive/paimon-hive-catalog/src/test/java/org/apache/paimon/hive/HiveCatalogTest.java
 
b/paimon-hive/paimon-hive-catalog/src/test/java/org/apache/paimon/hive/HiveCatalogTest.java
index 3043a57464..5e19606716 100644
--- 
a/paimon-hive/paimon-hive-catalog/src/test/java/org/apache/paimon/hive/HiveCatalogTest.java
+++ 
b/paimon-hive/paimon-hive-catalog/src/test/java/org/apache/paimon/hive/HiveCatalogTest.java
@@ -482,6 +482,27 @@ public class HiveCatalogTest extends CatalogTestBase {
                         Collections.singletonMap("dt", "20250101"));
     }
 
+    @Test
+    public void testCreateTableWithBlob() throws Exception {
+        String databaseName = "testCreateTableWithBlob";
+        catalog.dropDatabase(databaseName, true, true);
+        catalog.createDatabase(databaseName, true);
+        Identifier identifier = Identifier.create(databaseName, "table");
+        catalog.createTable(
+                identifier,
+                Schema.newBuilder()
+                        .option(METASTORE_TAG_TO_PARTITION.key(), "dt")
+                        .column("col", DataTypes.INT())
+                        .column("dt", DataTypes.STRING())
+                        .column("picture", DataTypes.BLOB())
+                        .option(CoreOptions.ROW_TRACKING_ENABLED.key(), "true")
+                        .option(CoreOptions.DATA_EVOLUTION_ENABLED.key(), 
"true")
+                        .build(),
+                true);
+
+        assertThat(catalog.listTables(databaseName)).contains("table");
+    }
+
     @Test
     public void testAlterPartitions() throws Exception {
         if (!supportPartitions()) {
diff --git 
a/paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java
 
b/paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java
index 844128539d..e4799341d1 100644
--- 
a/paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java
+++ 
b/paimon-hive/paimon-hive-common/src/main/java/org/apache/paimon/hive/HiveTypeUtils.java
@@ -22,6 +22,7 @@ import org.apache.paimon.data.variant.Variant;
 import org.apache.paimon.types.ArrayType;
 import org.apache.paimon.types.BigIntType;
 import org.apache.paimon.types.BinaryType;
+import org.apache.paimon.types.BlobType;
 import org.apache.paimon.types.BooleanType;
 import org.apache.paimon.types.CharType;
 import org.apache.paimon.types.DataField;
@@ -229,6 +230,11 @@ public class HiveTypeUtils {
             return TypeInfoFactory.getStructTypeInfo(fieldNames, typeInfos);
         }
 
+        @Override
+        public TypeInfo visit(BlobType blobType) {
+            return TypeInfoFactory.binaryTypeInfo;
+        }
+
         @Override
         protected TypeInfo defaultMethod(org.apache.paimon.types.DataType 
dataType) {
             throw new UnsupportedOperationException("Unsupported type: " + 
dataType);