File tree 1 file changed +3
-3
lines changed
datafusion/physical-plan/src/aggregates
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -890,7 +890,7 @@ impl GroupedHashAggregateStream {
890
890
let batches = outputs
891
891
. into_iter ( )
892
892
. map ( |o| {
893
- RecordBatch :: try_new ( schema . clone ( ) , o)
893
+ RecordBatch :: try_new ( Arc :: clone ( & schema ) , o)
894
894
. map_err ( |e| DataFusionError :: ArrowError ( e, None ) )
895
895
} )
896
896
. collect :: < Result < VecDeque < _ > > > ( ) ?;
@@ -1189,7 +1189,7 @@ impl MergeMode {
1189
1189
1190
1190
fn merge_groups_and_partial_states (
1191
1191
& self ,
1192
- outputs : & mut Vec < Vec < ArrayRef > > ,
1192
+ outputs : & mut [ Vec < ArrayRef > ] ,
1193
1193
mut partial_states : Vec < Vec < ArrayRef > > ,
1194
1194
) {
1195
1195
match & self {
@@ -1205,7 +1205,7 @@ impl MergeMode {
1205
1205
1206
1206
fn merge_groups_and_final_states (
1207
1207
& self ,
1208
- outputs : & mut Vec < Vec < ArrayRef > > ,
1208
+ outputs : & mut [ Vec < ArrayRef > ] ,
1209
1209
mut final_states : Vec < ArrayRef > ,
1210
1210
) {
1211
1211
match & self {
You can’t perform that action at this time.
0 commit comments