[ https://issues.apache.org/jira/browse/ARROW-18310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Weston Pace resolved ARROW-18310. --------------------------------- Resolution: Fixed Issue resolved by pull request 14622 [https://github.com/apache/arrow/pull/14622] > [C++] Use atomic backpressure counter > ------------------------------------- > > Key: ARROW-18310 > URL: https://issues.apache.org/jira/browse/ARROW-18310 > Project: Apache Arrow > Issue Type: Bug > Components: C++ > Reporter: Yaron Gvili > Assignee: Yaron Gvili > Priority: Major > Labels: pull-request-available > Fix For: 11.0.0, 10.0.1 > > Time Spent: 50m > Remaining Estimate: 0h > > There are a few places in the code (sink_node.cc, source_node.cc, > file_base.cc) where the backpressure counter is of type `int32_t`. This > prevents `ExecNode::Pause(...)` and `ExecNode::Resume(...)` from being > thread-safe. The proposal is to make these backpressure counters be of type > `std::atomic<int32_t>`. -- This message was sent by Atlassian Jira (v8.20.10#820010)