crepererum opened a new pull request #1112: URL: https://github.com/apache/arrow-datafusion/pull/1112
Follow up to #1105 and the second part of #1103. I've improved the testing a bit to make these kinds of tests less repetitive. The changes are mostly trivial except for `RepartitionExec`, because there: 1. we must only kill the background tasks once ALL consumers are gone, hence the `Arc<AbortOnDrop>` 2. the nested task structure is a bit more tricky to get right, hence the new `WaitForTask` struct that replaces the async `wait_for_task` function. It does the same thing but ensures that the captured join handle is aborted on drop. -- 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]
