rangadi opened a new pull request, #43023:
URL: https://github.com/apache/spark/pull/43023
### What changes were proposed in this pull request?
`createSimpleWorker()` method in `PythonWorkerFactory` waits forever if the
worker fails to connect back to the server.
This is because it calls accept() without a timeout. If the worker does not
connect back, accept() waits forever. There is supposed to be 10 seconds
timeout, but it was not implemented correctly.
This PR adds a 10 second timeout.
### Why are the changes needed?
Otherwise create method could be stuck forever.
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
- Unit test
- Manual
### Was this patch authored or co-authored using generative AI tooling?
Generated-by: ChatGPT 4.0
Asked ChatGPT to generate sample code to do non-blocking accept() on a
socket channel in Java.
--
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: reviews-unsubscr...@spark.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
