File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed
crates/integrations/datafusion/src/physical_plan Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -84,7 +84,10 @@ impl IcebergCommitExec {
84
84
let count_array = Arc :: new ( UInt64Array :: from ( vec ! [ count] ) ) as ArrayRef ;
85
85
86
86
RecordBatch :: try_from_iter_with_nullable ( vec ! [ ( "count" , count_array, false ) ] ) . map_err ( |e| {
87
- DataFusionError :: ArrowError ( e, Some ( "Failed to make count batch!" . to_string ( ) ) )
87
+ DataFusionError :: ArrowError (
88
+ Box :: new ( e) ,
89
+ Some ( "Failed to make count batch!" . to_string ( ) ) ,
90
+ )
88
91
} )
89
92
}
90
93
Original file line number Diff line number Diff line change @@ -100,7 +100,10 @@ impl IcebergWriteExec {
100
100
let files_array = Arc :: new ( StringArray :: from ( data_files) ) as ArrayRef ;
101
101
102
102
RecordBatch :: try_new ( Self :: make_result_schema ( ) , vec ! [ files_array] ) . map_err ( |e| {
103
- DataFusionError :: ArrowError ( e, Some ( "Failed to make result batch" . to_string ( ) ) )
103
+ DataFusionError :: ArrowError (
104
+ Box :: new ( e) ,
105
+ Some ( "Failed to make result batch" . to_string ( ) ) ,
106
+ )
104
107
} )
105
108
}
106
109
You can’t perform that action at this time.
0 commit comments