This is an automated email from the ASF dual-hosted git repository.
liurenjie1024 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg-rust.git
The following commit(s) were added to refs/heads/main by this push:
new 61af83b1 fix type promote (#685)
61af83b1 is described below
commit 61af83b16b86b37143093ffcfe76d8e775f2363c
Author: Dylan <[email protected]>
AuthorDate: Fri Nov 1 17:42:04 2024 +0800
fix type promote (#685)
---
crates/iceberg/src/arrow/record_batch_transformer.rs | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/crates/iceberg/src/arrow/record_batch_transformer.rs
b/crates/iceberg/src/arrow/record_batch_transformer.rs
index 216e68ea..9a4dd178 100644
--- a/crates/iceberg/src/arrow/record_batch_transformer.rs
+++ b/crates/iceberg/src/arrow/record_batch_transformer.rs
@@ -143,8 +143,9 @@ impl RecordBatchTransformer {
ref target_schema,
ref operations,
}) => {
- let options =
-
RecordBatchOptions::default().with_row_count(Some(record_batch.num_rows()));
+ 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(),
self.transform_columns(record_batch.columns(),
operations)?,