icexelloss commented on PR #35874: URL: https://github.com/apache/arrow/pull/35874#issuecomment-1573881515
> IMO, both (1) and (2) above could be flaky due to non-deterministic timing I think this can be avoided if we make sure the slow sink is blocking. i.e. ``` slow_sink.pause_processing() # make sure slow_sink stop processing so what we can trigger backpresure # validate backpresure is triggered slow_sink.resume_processing() # validate plan exists normally and resume counter is expected ``` -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
