diff --git a/crates/iceberg/src/arrow/record_batch_transformer.rs b/crates/iceberg/src/arrow/record_batch_transformer.rs index f231e0f2e2..779f1cc625 100644 --- a/crates/iceberg/src/arrow/record_batch_transformer.rs +++ b/crates/iceberg/src/arrow/record_batch_transformer.rs @@ -153,7 +153,14 @@ impl RecordBatchTransformer { )? } Some(BatchTransform::ModifySchema { target_schema }) => { - record_batch.with_schema(target_schema.clone())? + let options = RecordBatchOptions::default() + .with_match_field_names(false) + .with_row_count(Some(record_batch.num_rows())); + RecordBatch::try_new_with_options( + target_schema.clone(), + record_batch.columns().to_vec(), + &options, + )? } None => { self.batch_transform = Some(Self::generate_batch_transform(