juliuszsompolski opened a new pull request, #42304: URL: https://github.com/apache/spark/pull/42304
### What changes were proposed in this pull request? When server returns error on the response stream via onError, the ExecutePlanResponseReattachableIterator will not see the stream finish with a ResultsComplete. Instead, a StatusRuntimeException will be thrown from next() or hasNext(). Handle catching that exception, telling the server to ReleaseExecute when we receive it, and rethrow it to the user. ### Why are the changes needed? If ReleaseExecute is not called by the client to acknowledge that the error was received, the execution will keep dangling on the server until cleaned up by timeout. ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Automated tests will come with https://issues.apache.org/jira/browse/SPARK-44625. -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
