Update asof_join_node.cc

Co-authored-by: Benjamin Kietzman <[email protected]>
JerAguilon · Oct 23, 2023 · 5d8b709 · 5d8b709
1 parent ae30a33
commit 5d8b709
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cpp/src/arrow/acero/asof_join_node.cc b/cpp/src/arrow/acero/asof_join_node.cc
@@ -1702,8 +1702,8 @@ class AsofJoinNode : public ExecNode {
 
   Status InputReceived(ExecNode* input, ExecBatch batch) override {
     // InputReceived may be called after execution was finished. Pushing it to the
-    // InputState may cause the BackPressureController to pause the input, causing a
-    // deadlock
+    // InputState is unnecessary since we're done (and anyway may cause the
+    // BackPressureController to pause the input, causing a deadlock), so drop it.
     if (process_task_.is_finished()) {
       DEBUG_SYNC(this, "Input received while done. Short circuiting.",
                  DEBUG_MANIP(std::endl));