Github user zsxwing commented on a diff in the pull request:
https://github.com/apache/spark/pull/22770#discussion_r226459609
--- Diff:
core/src/main/scala/org/apache/spark/api/python/PythonWorkerFactory.scala ---
@@ -163,7 +172,9 @@ private[spark] class PythonWorkerFactory(pythonExec:
String, envVars: Map[String
try {
val socket = serverSocket.accept()
authHelper.authClient(socket)
- simpleWorkers.put(socket, worker)
+ self.synchronized {
--- End diff --
this is fix 2.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
