We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 59a3428 commit 3b4dc9dCopy full SHA for 3b4dc9d
crates/integrations/datafusion/src/physical_plan/write.rs
@@ -89,10 +89,9 @@ impl IcebergWriteExec {
89
fn make_result_batch(data_files: Vec<String>) -> DFResult<RecordBatch> {
90
let files_array = Arc::new(StringArray::from(data_files)) as ArrayRef;
91
92
- RecordBatch::try_from_iter_with_nullable(vec![(DATA_FILES_COL_NAME, files_array, false)])
93
- .map_err(|e| {
94
- DataFusionError::ArrowError(e, Some("Failed to make result batch".to_string()))
95
- })
+ RecordBatch::try_new(Self::make_result_schema(), vec![files_array]).map_err(|e| {
+ DataFusionError::ArrowError(e, Some("Failed to make result batch".to_string()))
+ })
96
}
97
98
fn make_result_schema() -> ArrowSchemaRef {
0 commit comments