File tree Expand file tree Collapse file tree 3 files changed +9
-3
lines changed
crates/integrations/datafusion/src Expand file tree Collapse file tree 3 files changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -84,7 +84,10 @@ impl IcebergCommitExec {
8484 let count_array = Arc :: new ( UInt64Array :: from ( vec ! [ count] ) ) as ArrayRef ;
8585
8686 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+ )
8891 } )
8992 }
9093
Original file line number Diff line number Diff line change @@ -100,7 +100,10 @@ impl IcebergWriteExec {
100100 let files_array = Arc :: new ( StringArray :: from ( data_files) ) as ArrayRef ;
101101
102102 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+ )
104107 } )
105108 }
106109
Original file line number Diff line number Diff line change @@ -241,7 +241,7 @@ mod tests {
241241 options : Default :: default ( ) ,
242242 table_partition_cols : Default :: default ( ) ,
243243 order_exprs : Default :: default ( ) ,
244- constraints : Constraints :: empty ( ) ,
244+ constraints : Constraints :: default ( ) ,
245245 column_defaults : Default :: default ( ) ,
246246 if_not_exists : Default :: default ( ) ,
247247 temporary : false ,
You can’t perform that action at this time.
0 commit comments