alamb opened a new pull request, #6507: URL: https://github.com/apache/arrow-datafusion/pull/6507
# Which issue does this PR close? Based on https://github.com/apache/arrow-datafusion/pull/6449 from @nvartolomei Closes https://github.com/apache/arrow-datafusion/issues/3104 # Rationale for this change I wanted to fix # What changes are included in this PR? 2. Add a `RecordBatchReceiverStreamBuilder` which handles doing the abort-on-drop dance using [tokio::task::JoinSet](https://docs.rs/tokio/latest/tokio/task/struct.JoinSet.html) as shown by @nvartolomei 3. Port `CoalsceExec` and `AnalyzeExec` to use this builder # Are these changes tested? Covered by existing tests # Are there any user-facing changes? Yes, panic's are not ignored -- 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]
