Skip to content

Commit c26805d

Browse files
committed
fix process_record_batch and don't check field names
1 parent 13a561f commit c26805d

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

crates/iceberg/src/arrow/record_batch_transformer.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,8 +143,9 @@ impl RecordBatchTransformer {
143143
ref target_schema,
144144
ref operations,
145145
}) => {
146-
let options =
147-
RecordBatchOptions::default().with_row_count(Some(record_batch.num_rows()));
146+
let options = RecordBatchOptions::default()
147+
.with_match_field_names(false)
148+
.with_row_count(Some(record_batch.num_rows()));
148149
RecordBatch::try_new_with_options(
149150
target_schema.clone(),
150151
self.transform_columns(record_batch.columns(), operations)?,

0 commit comments

Comments
 (0)