Re-use the thread created for running the gateway.

Marcelo Vanzin · Marcelo Vanzin · commit 30b0ee5edba2 · 2015-08-17T16:48:35.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/deploy/PythonRunner.scala b/core/src/main/scala/org/apache/spark/deploy/PythonRunner.scala
@@ -49,7 +49,7 @@ object PythonRunner {
     val gatewayServer = new py4j.GatewayServer(null, 0)
     val thread = new Thread(new Runnable() {
       override def run(): Unit = Utils.logUncaughtExceptions {
-        gatewayServer.start()
+        gatewayServer.start(false)
       }
     })
     thread.setName("py4j-gateway")

Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,7 @@ object PythonRunner {`
`49`	`49`	`val gatewayServer = new py4j.GatewayServer(null, 0)`
`50`	`50`	`val thread = new Thread(new Runnable() {`
`51`	`51`	`override def run(): Unit = Utils.logUncaughtExceptions {`
`52`		`- gatewayServer.start()`
	`52`	`+ gatewayServer.start(false)`
`53`	`53`	`}`
`54`	`54`	`})`
`55`	`55`	`thread.setName("py4j-gateway")`