Revert "Move RBackend to member variable" (apache#345)

mccheah · Mar 30, 2018 · 1010acc · 1010acc
1 parent bb10a57
commit 1010acc
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/deploy/RRunner.scala b/core/src/main/scala/org/apache/spark/deploy/RRunner.scala
@@ -40,8 +40,6 @@ import org.apache.spark.util.RedirectThread
  * subprocess and then has it connect back to the JVM to access system properties etc.
  */
 object RRunner extends CondaRunner with Logging {
-  val sparkRBackend = new RBackend()
-
   override def run(args: Array[String], maybeConda: Option[CondaEnvironment]): Unit = {
     val rFile = PythonRunner.formatPath(args(0))
 
@@ -86,6 +84,7 @@ object RRunner extends CondaRunner with Logging {
 
     // Launch a SparkR backend server for the R process to connect to; this will let it see our
     // Java system properties etc.
+    val sparkRBackend = new RBackend()
     @volatile var sparkRBackendPort = 0
     val initialized = new Semaphore(0)
     val sparkRBackendThread = new Thread("SparkR backend") {