gitmodimo opened a new pull request, #47386: URL: https://github.com/apache/arrow/pull/47386
### Rationale for this change Current BackpressureHandler needs to be provided with ExecNode, however the backpressure concept can be applied outside of ExecNode. It is currently needed to Facilitate ForceShutdown in AsofJoinNode. Current implementation however is not elegant and may still lead to deadlock after ForceShutdown in extreme case - when several batched get pushed after ForceShutdown and exceed the threshold. ### What changes are included in this PR? -Remove ForceShutdown from BackpressureHandler. -Reimplement ForceShutdown in BackpressureConcurrentQueue as onetime nonrecoverable queue clear that effectively unpauses source using handler. ### Are these changes tested? There is no new functionality. Current tests should cover it. ### Are there any user-facing changes? No -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@arrow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
