File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
datafusion/physical-plan/src/aggregates Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1360,7 +1360,7 @@ mod tests {
13601360 ) ] ;
13611361
13621362 let exec = TestMemoryExec :: try_new ( & input_partitions, Arc :: clone ( & schema) , None ) ?;
1363- let exec = Arc :: new ( TestMemoryExec :: update_cache ( Arc :: new ( exec) ) ) ;
1363+ let exec = Arc :: new ( TestMemoryExec :: update_cache ( & Arc :: new ( exec) ) ) ;
13641364
13651365 // Use Partial mode where the race condition occurs
13661366 let aggregate_exec = AggregateExec :: try_new (
@@ -1374,7 +1374,7 @@ mod tests {
13741374
13751375 // Execute and collect results
13761376 let mut stream =
1377- GroupedHashAggregateStream :: new ( & aggregate_exec, Arc :: clone ( & task_ctx) , 0 ) ?;
1377+ GroupedHashAggregateStream :: new ( & aggregate_exec, & Arc :: clone ( & task_ctx) , 0 ) ?;
13781378 let mut results = Vec :: new ( ) ;
13791379
13801380 while let Some ( result) = stream. next ( ) . await {
You can’t perform that action at this time.
0 commit comments