Skip to content

Commit ac7e3dc

Browse files
author
Rafał Hibner
committed
Fix build
1 parent 0402250 commit ac7e3dc

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

cpp/src/arrow/acero/groupby_aggregate_node.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ Status GroupByNode::Init() {
8585

8686
constexpr size_t low_threshold = 4, high_threshold = 8;
8787
ARROW_ASSIGN_OR_RAISE(auto handler, BackpressureHandler::Make(
88-
this, low_threshold, high_threshold,
88+
low_threshold, high_threshold,
8989
std::move(backpressure_source_sequencer_)));
9090

9191
processor_ = acero::util::SerialSequencingQueue::Processor::MakeBackpressureWrapper(

cpp/src/arrow/acero/scalar_aggregate_node.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -248,7 +248,7 @@ Status ScalarAggregateNode::Init() {
248248

249249
constexpr size_t low_threshold = 4, high_threshold = 8;
250250
ARROW_ASSIGN_OR_RAISE(auto handler, BackpressureHandler::Make(
251-
this, low_threshold, high_threshold,
251+
low_threshold, high_threshold,
252252
std::move(backpressure_source_sequencer_)));
253253

254254
processor_ = acero::util::SerialSequencingQueue::Processor::MakeBackpressureWrapper(

0 commit comments

Comments
 (0)