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 bfb6297fae3f..419000fd8614 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 @@ -19,7 +19,6 @@ package org.apache.paimon.format.parquet; import org.apache.paimon.data.variant.Variant; -import org.apache.paimon.data.variant.VariantMetadataUtils; import org.apache.paimon.table.SpecialFields; import org.apache.paimon.types.ArrayType; import org.apache.paimon.types.DataField; @@ -215,17 +214,17 @@ public static Type convertToParquetType(String name, DataType type, int fieldId, case ROW: RowType rowType = (RowType) type; Types.GroupBuilder groupTypeBuilder = Types.buildGroup(repetition); - if (VariantMetadataUtils.isVariantRowType(rowType)) { - groupTypeBuilder.as( - LogicalTypeAnnotation.variantType(Variant.VARIANT_SPEC_VERSION)); - } + // if (VariantMetadataUtils.isVariantRowType(rowType)) { + // groupTypeBuilder.as( + // LogicalTypeAnnotation.variantType(Variant.VARIANT_SPEC_VERSION)); + // } return groupTypeBuilder .addFields(convertToParquetTypes(rowType)) .named(name) .withId(fieldId); case VARIANT: return Types.buildGroup(repetition) - .as(LogicalTypeAnnotation.variantType(Variant.VARIANT_SPEC_VERSION)) + // .as(LogicalTypeAnnotation.variantType(Variant.VARIANT_SPEC_VERSION)) .addField( Types.primitive( PrimitiveType.PrimitiveTypeName.BINARY, diff --git a/paimon-format/src/test/java/org/apache/paimon/format/parquet/writer/InferVariantShreddingWriteTest.java b/paimon-format/src/test/java/org/apache/paimon/format/parquet/writer/InferVariantShreddingWriteTest.java index 52a1618c02ce..4dc7c2b27385 100644 --- a/paimon-format/src/test/java/org/apache/paimon/format/parquet/writer/InferVariantShreddingWriteTest.java +++ b/paimon-format/src/test/java/org/apache/paimon/format/parquet/writer/InferVariantShreddingWriteTest.java @@ -49,6 +49,7 @@ import org.apache.parquet.schema.MessageType; import org.apache.parquet.schema.Type; import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Disabled; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.io.TempDir; import org.junit.jupiter.params.ParameterizedTest; @@ -557,6 +558,7 @@ protected void verifyShreddingSchema(RowType... expectShreddedTypes) throws IOEx } } + @Disabled @ParameterizedTest @ValueSource(booleans = {false, true}) public void testVariantTypeAnnotation(boolean inferShredding) throws Exception {