Skip to content

Commit e5e03a2

Browse files
author
Rafał Hibner
committed
Update backpressure counter
1 parent adcbe2c commit e5e03a2

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

cpp/src/arrow/acero/pipe_node.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -278,6 +278,7 @@ void Pipe::Pause(PipeSource* output, int counter) {
278278
auto lock = mutex_.Lock();
279279
auto& state = state_[output];
280280
if (state.backpressure_counter < counter) {
281+
state.backpressure_counter = counter;
281282
if (!state.paused && !state.stopped) {
282283
state.paused = true;
283284
size_t paused_count = ++paused_count_;

0 commit comments

Comments
 (0)