Skip to content

Commit 12a8c2f

Browse files
committed
remove check for schema before reading column orders
1 parent a05f149 commit 12a8c2f

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

parquet/src/file/metadata/thrift_gen.rs

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1182,9 +1182,6 @@ pub(crate) fn parquet_metadata_from_bytes(buf: &[u8]) -> Result<ParquetMetaData>
11821182
created_by = Some(<&str>::read_thrift(&mut prot)?);
11831183
}
11841184
7 => {
1185-
if schema_descr.is_none() {
1186-
return Err(general_err!("Required field schema is missing"));
1187-
}
11881185
let val = read_thrift_vec::<ColumnOrder, ThriftSliceInputProtocol>(&mut prot)?;
11891186
column_orders = Some(val);
11901187
}

parquet/src/file/serialized_reader.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1896,7 +1896,7 @@ mod tests {
18961896
let ret = SerializedFileReader::new(Bytes::copy_from_slice(&data));
18971897
assert_eq!(
18981898
ret.err().unwrap().to_string(),
1899-
"Parquet error: Required field schema is missing"
1899+
"Parquet error: Received empty union from remote ColumnOrder"
19001900
);
19011901
}
19021902

0 commit comments

Comments
 (0)