Skip to content
This repository has been archived by the owner on Feb 18, 2024. It is now read-only.

Commit

Permalink
Allow different versions between message and file
Browse files Browse the repository at this point in the history
  • Loading branch information
jorgecarleitao committed Dec 13, 2021
1 parent ad2f62a commit f9e7dd8
Showing 1 changed file with 0 additions and 8 deletions.
8 changes: 0 additions & 8 deletions src/io/ipc/read/reader.rs
Original file line number Diff line number Diff line change
Expand Up @@ -244,14 +244,6 @@ pub fn read_batch<R: Read + Seek>(
let message = ipc::Message::root_as_message(&block_data[..])
.map_err(|err| ArrowError::OutOfSpec(format!("Unable to get root as footer: {:?}", err)))?;

// some old test data's footer metadata is not set, so we account for that
if metadata.version != ipc::Schema::MetadataVersion::V1 && message.version() != metadata.version
{
return Err(ArrowError::OutOfSpec(
format!("Could not read IPC message as metadata versions mismatch: metadata version {:?}, message version {:?}", metadata.version, message.version())
));
}

let batch = get_serialized_batch(&message)?;

read_record_batch(
Expand Down

0 comments on commit f9e7dd8

Please sign in to comment.