We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 3cf060e + d8d36eb commit c4115abCopy full SHA for c4115ab
1 file changed
cpp/src/arrow/acero/asof_join_node.cc
@@ -1063,7 +1063,13 @@ class AsofJoinNode : public ExecNode {
1063
bool Process() {
1064
// Process batches while we have data
1065
for (;;) {
1066
- backpressure_future_.Wait();
+ Future<> to_wait;
1067
+ {
1068
+ std::lock_guard<std::mutex> lg(backpressure_mutex_);
1069
+ to_wait = backpressure_future_;
1070
+ }
1071
+ to_wait.Wait();
1072
+
1073
Result<std::shared_ptr<RecordBatch>> result;
1074
{
1075
std::lock_guard<std::mutex> guard(gate_);
0 commit comments