Skip to content

Commit c821c78

Browse files
author
Rafał Hibner
committed
Fix after merge
1 parent e9d41a5 commit c821c78

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

cpp/src/arrow/acero/groupby_aggregate_node.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ Status GroupByNode::Init() {
7070
std::unique_ptr<arrow::acero::BackpressureControl> backpressure_control =
7171
std::make_unique<BackpressureController>(inputs_[0], this);
7272
ARROW_ASSIGN_OR_RAISE(auto handler,
73-
BackpressureHandler::Make(this, low_threshold, high_threshold,
73+
BackpressureHandler::Make(low_threshold, high_threshold,
7474
std::move(backpressure_control)));
7575

7676
processor_ = acero::util::SerialSequencingQueue::Processor::MakeBackpressureWrapper(
@@ -507,4 +507,4 @@ Status GroupByNode::InitLocalStateIfNeeded(ThreadLocalState* state) {
507507

508508
} // namespace aggregate
509509
} // namespace acero
510-
} // namespace arrow
510+
} // namespace arrow

cpp/src/arrow/acero/scalar_aggregate_node.cc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ Status ScalarAggregateNode::Init() {
235235
std::unique_ptr<arrow::acero::BackpressureControl> backpressure_control =
236236
std::make_unique<BackpressureController>(inputs_[0], this);
237237
ARROW_ASSIGN_OR_RAISE(auto handler,
238-
BackpressureHandler::Make(this, low_threshold, high_threshold,
238+
BackpressureHandler::Make(low_threshold, high_threshold,
239239
std::move(backpressure_control)));
240240

241241
processor_ = acero::util::SerialSequencingQueue::Processor::MakeBackpressureWrapper(
@@ -376,4 +376,4 @@ Status ScalarAggregateNode::OutputResult(bool is_last) {
376376

377377
} // namespace aggregate
378378
} // namespace acero
379-
} // namespace arrow
379+
} // namespace arrow

0 commit comments

Comments
 (0)