File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
datafusion/physical-plan/src/aggregates Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -890,7 +890,7 @@ impl GroupedHashAggregateStream {
890890 let batches = outputs
891891 . into_iter ( )
892892 . map ( |o| {
893- RecordBatch :: try_new ( schema . clone ( ) , o)
893+ RecordBatch :: try_new ( Arc :: clone ( & schema ) , o)
894894 . map_err ( |e| DataFusionError :: ArrowError ( e, None ) )
895895 } )
896896 . collect :: < Result < VecDeque < _ > > > ( ) ?;
@@ -1189,7 +1189,7 @@ impl MergeMode {
11891189
11901190 fn merge_groups_and_partial_states (
11911191 & self ,
1192- outputs : & mut Vec < Vec < ArrayRef > > ,
1192+ outputs : & mut [ Vec < ArrayRef > ] ,
11931193 mut partial_states : Vec < Vec < ArrayRef > > ,
11941194 ) {
11951195 match & self {
@@ -1205,7 +1205,7 @@ impl MergeMode {
12051205
12061206 fn merge_groups_and_final_states (
12071207 & self ,
1208- outputs : & mut Vec < Vec < ArrayRef > > ,
1208+ outputs : & mut [ Vec < ArrayRef > ] ,
12091209 mut final_states : Vec < ArrayRef > ,
12101210 ) {
12111211 match & self {
You can’t perform that action at this time.
0 commit comments