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 667218f commit 047fd9aCopy full SHA for 047fd9a
cpp/src/arrow/acero/pipe_node.h
@@ -110,10 +110,10 @@ class ARROW_ACERO_EXPORT Pipe {
110
// backpressure
111
std::unordered_map<PipeSource*, bool> paused_;
112
std::mutex mutex_;
113
- std::atomic_size_t paused_count_;
+ std::atomic_size_t paused_count_{0};
114
std::unique_ptr<BackpressureControl> ctrl_;
115
// stopProducing
116
- std::atomic_size_t stopped_count_;
+ std::atomic_size_t stopped_count_{0};
117
std::function<Status()> stopProducing_;
118
119
const bool pause_on_any_;
0 commit comments