Skip to content

Commit 7740250

Browse files
committed
fix: map parquet field_id correctly (native_iceberg_compat)
1 parent a3ac6e4 commit 7740250

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

common/src/main/java/org/apache/comet/parquet/NativeBatchReader.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -283,6 +283,8 @@ public void init() throws Throwable {
283283
sparkSchema.size(), requestedSchema.getFieldCount()));
284284
}
285285
}
286+
// Convert clipped schema back to a Spark schema
287+
sparkSchema = converter.convert(requestedSchema);
286288
this.parquetColumn =
287289
converter.convertParquetColumn(requestedSchema, Option.apply(this.sparkSchema));
288290

0 commit comments

Comments
 (0)