Skip to content

Commit dbda9af

Browse files
author
Rafał Hibner
committed
Fix SortedMergeStop
1 parent c38cc5b commit dbda9af

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

cpp/src/arrow/acero/sorted_merge_node.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -278,6 +278,7 @@ class SortedMergeNode : public ExecNode {
278278
#ifdef ARROW_ENABLE_THREADING
279279
if (process_thread.joinable()) {
280280
process_thread.join();
281+
return;
281282
}
282283
#endif
283284
}

0 commit comments

Comments
 (0)