We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ad7bcab commit 206d8a2Copy full SHA for 206d8a2
cpp/src/arrow/dataset/dataset_writer.cc
@@ -61,12 +61,11 @@ class Throttle {
61
if (current_value_ >= max_value_) {
62
in_waiting_ = values;
63
backpressure_ = Future<>::Make();
64
- } else {
65
- current_value_ += values;
66
- DCHECK(backpressure_.is_finished());
67
- return std::nullopt;
+ return backpressure_;
68
}
69
- return backpressure_;
+ current_value_ += values;
+ DCHECK(backpressure_.is_finished());
+ return std::nullopt;
70
71
72
void Release(uint64_t values) {
0 commit comments