Propagate backpressure in hash aggregate node

Rafał Hibner · Rafał Hibner · commit bcf3f8f3cf64 · 2025-08-13T14:09:07.000Z
diff --git a/cpp/src/arrow/acero/aggregate_internal.h b/cpp/src/arrow/acero/aggregate_internal.h
@@ -293,13 +293,11 @@ class GroupByNode : public ExecNode, public TracedNode {
   }
 
   void PauseProducing(ExecNode* output, int32_t counter) override {
-    // TODO(ARROW-16260)
-    // Without spillover there is no way to handle backpressure in this node
+    inputs_[0]->PauseProducing(this, counter);
   }
 
   void ResumeProducing(ExecNode* output, int32_t counter) override {
-    // TODO(ARROW-16260)
-    // Without spillover there is no way to handle backpressure in this node
+    inputs_[0]->ResumeProducing(this, counter);
   }
 
   Status StopProducingImpl() override { return Status::OK(); }

Original file line number	Diff line number	Diff line change
`@@ -293,13 +293,11 @@ class GroupByNode : public ExecNode, public TracedNode {`
`293`	`293`	`}`
`294`	`294`
`295`	`295`	`void PauseProducing(ExecNode* output, int32_t counter) override {`
`296`		`- // TODO(ARROW-16260)`
`297`		`- // Without spillover there is no way to handle backpressure in this node`
	`296`	`+ inputs_[0]->PauseProducing(this, counter);`
`298`	`297`	`}`
`299`	`298`
`300`	`299`	`void ResumeProducing(ExecNode* output, int32_t counter) override {`
`301`		`- // TODO(ARROW-16260)`
`302`		`- // Without spillover there is no way to handle backpressure in this node`
	`300`	`+ inputs_[0]->ResumeProducing(this, counter);`
`303`	`301`	`}`
`304`	`302`
`305`	`303`	`Status StopProducingImpl() override { return Status::OK(); }`