Skip to content

Commit 65850a5

Browse files
author
Rafał Hibner
committed
Fix sorted_merge hide actual source of stop
1 parent ac7e3dc commit 65850a5

1 file changed

Lines changed: 0 additions & 8 deletions

File tree

cpp/src/arrow/acero/sorted_merge_node.cc

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -480,12 +480,6 @@ class SortedMergeNode : public ExecNode {
480480

481481
private:
482482
void EndFromProcessThread(arrow::Status st = arrow::Status::OK()) {
483-
ARROW_CHECK(!cleanup_started);
484-
for (size_t i = 0; i < input_counter.size(); ++i) {
485-
ARROW_CHECK(input_counter[i] == output_counter[i])
486-
<< input_counter[i] << " != " << output_counter[i];
487-
}
488-
489483
#ifdef ARROW_ENABLE_THREADING
490484
ARROW_UNUSED(
491485
plan_->query_context()->executor()->Spawn([this, st = std::move(st)]() mutable {
@@ -670,8 +664,6 @@ class SortedMergeNode : public ExecNode {
670664
std::vector<std::atomic_int64_t> output_counter;
671665
std::mutex gate;
672666

673-
std::atomic<bool> cleanup_started{false};
674-
675667
// Backpressure counter common to all input states
676668
std::atomic<int32_t> backpressure_counter{0};
677669

0 commit comments

Comments
 (0)