(paimon) branch master updated: [hotfix] Add Variant TODO in ParquetSchemaConverter

[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 8a54967a38 [hotfix] Add Variant TODO in ParquetSchemaConverter
8a54967a38 is described below

commit 8a54967a3826d22a63c22504fe487b85efb690b1
Author: JingsongLi <jingsongl...@gmail.com>
AuthorDate: Sat Jan 31 18:36:18 2026 +0800

    [hotfix] Add Variant TODO in ParquetSchemaConverter
---
 .../java/org/apache/paimon/format/parquet/ParquetSchemaConverter.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetSchemaConverter.java
 
b/paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetSchemaConverter.java
index 419000fd86..f5d93bec42 100644
--- 
a/paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetSchemaConverter.java
+++ 
b/paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetSchemaConverter.java
@@ -214,6 +214,7 @@ public class ParquetSchemaConverter {
             case ROW:
                 RowType rowType = (RowType) type;
                 Types.GroupBuilder<GroupType> groupTypeBuilder = 
Types.buildGroup(repetition);
+                // TODO Use Variant until all engines are upgraded to the 
latest Parquet
                 // if (VariantMetadataUtils.isVariantRowType(rowType)) {
                 //     groupTypeBuilder.as(
                 //            
LogicalTypeAnnotation.variantType(Variant.VARIANT_SPEC_VERSION));
@@ -224,6 +225,7 @@ public class ParquetSchemaConverter {
                         .withId(fieldId);
             case VARIANT:
                 return Types.buildGroup(repetition)
+                        // TODO Use Variant until all engines are upgraded to 
the latest Parquet
                         // 
.as(LogicalTypeAnnotation.variantType(Variant.VARIANT_SPEC_VERSION))
                         .addField(
                                 Types.primitive(