Fix SortedMergeStop

Rafał Hibner · Rafał Hibner · commit 74ec06a85333 · 2025-09-25T10:07:20.000Z
diff --git a/cpp/src/arrow/acero/sorted_merge_node.cc b/cpp/src/arrow/acero/sorted_merge_node.cc
@@ -590,6 +590,7 @@ class SortedMergeNode : public ExecNode {
       // Implementation note: If the queue is empty, we will block here
       if (process_queue.WaitAndPop() == kPoisonPill) {
         EndFromProcessThread();
+        return;
       }
       // Either we're out of data or something went wrong
       if (!PollOnce()) {

Original file line number	Diff line number	Diff line change
`@@ -590,6 +590,7 @@ class SortedMergeNode : public ExecNode {`
`590`	`590`	`// Implementation note: If the queue is empty, we will block here`
`591`	`591`	`if (process_queue.WaitAndPop() == kPoisonPill) {`
`592`	`592`	`EndFromProcessThread();`
	`593`	`+ return;`
`593`	`594`	`}`
`594`	`595`	`// Either we're out of data or something went wrong`
`595`	`596`	`if (!PollOnce()) {`