From b59a6a9695f85f1c61051bd17087ddd9b9aeec13 Mon Sep 17 00:00:00 2001 From: Jefffrey Date: Sat, 22 Nov 2025 11:32:35 +0900 Subject: [PATCH] chore: fix CI on main --- datafusion/physical-plan/src/aggregates/row_hash.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/datafusion/physical-plan/src/aggregates/row_hash.rs b/datafusion/physical-plan/src/aggregates/row_hash.rs index 42f1fb016cc7e..3a1560d9ef16e 100644 --- a/datafusion/physical-plan/src/aggregates/row_hash.rs +++ b/datafusion/physical-plan/src/aggregates/row_hash.rs @@ -1360,7 +1360,7 @@ mod tests { )]; let exec = TestMemoryExec::try_new(&input_partitions, Arc::clone(&schema), None)?; - let exec = Arc::new(TestMemoryExec::update_cache(Arc::new(exec))); + let exec = Arc::new(TestMemoryExec::update_cache(&Arc::new(exec))); // Use Partial mode where the race condition occurs let aggregate_exec = AggregateExec::try_new( @@ -1374,7 +1374,7 @@ mod tests { // Execute and collect results let mut stream = - GroupedHashAggregateStream::new(&aggregate_exec, Arc::clone(&task_ctx), 0)?; + GroupedHashAggregateStream::new(&aggregate_exec, &Arc::clone(&task_ctx), 0)?; let mut results = Vec::new(); while let Some(result) = stream.next().await {