This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 8b3725aecc chore: fix CI on main (#18876)
8b3725aecc is described below
commit 8b3725aecc1e5803b3e7063bc15218131fe59470
Author: Jeffrey Vo <[email protected]>
AuthorDate: Sat Nov 22 13:41:52 2025 +1100
chore: fix CI on main (#18876)
---
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 42f1fb016c..3a1560d9ef 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 {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
