diff --git a/parquet/src/main/java/org/apache/iceberg/parquet/TypeToMessageType.java b/parquet/src/main/java/org/apache/iceberg/parquet/TypeToMessageType.java index 9f55670eda90..d1d60d2307a1 100644 --- a/parquet/src/main/java/org/apache/iceberg/parquet/TypeToMessageType.java +++ b/parquet/src/main/java/org/apache/iceberg/parquet/TypeToMessageType.java @@ -179,7 +179,10 @@ public Type primitive(PrimitiveType primitive, Type.Repetition repetition, int i } case UUID: - return Types.primitive(FIXED_LEN_BYTE_ARRAY, repetition).length(16).id(id).named(name); + return Types.primitive(FIXED_LEN_BYTE_ARRAY, repetition).length(16) + .as(LogicalTypeAnnotation.uuidType()) + .id(id) + .named(name); default: throw new UnsupportedOperationException("Unsupported type for Parquet: " + primitive);