juliuszsompolski opened a new pull request, #42560:
URL: https://github.com/apache/spark/pull/42560

   ### What changes were proposed in this pull request?
   
   Add `SparkConnectServerTest` with infra to test real server with real client 
in the same process, but communicating over RPC.
   
   Add `ReattachableExecuteSuite` with some tests for reattachable execute.
   
   One bug was found by the tests:
   Fix bug in `SparkConnectExecutionManager.createExecuteHolder` when 
attempting to resubmit an operation that was deemed abandoned. This bug is 
benign in reattachable execute, because reattachable execute would first send a 
ReattachExecute, which would be handled correctly in 
SparkConnectReattachExecuteHandler. For non-reattachable execute (disabled or 
old client), this is also a very unlikely scenario, because the retrying 
mechanism should be able to resubmit before the query is declared abandoned, 
and hence get an INVALID_HANDLE.OPERATION_ALREADY_EXISTS. This bug can manifest 
only if a non-reattachable execution is retried with so much delay that the 
operation was declared abandoned.
   
   ### Why are the changes needed?
   
   Testing of reattachable execute.
   
   ### Does this PR introduce _any_ user-facing change?
   
   No.
   
   ### How was this patch tested?
   
   Tests added.


-- 
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]

Reply via email to