From 1010acc31543cf2c8db9396c3877d941b3dedaf1 Mon Sep 17 00:00:00 2001 From: Patrick Woody Date: Fri, 30 Mar 2018 17:34:22 -0400 Subject: [PATCH] Revert "Move RBackend to member variable" (#345) --- core/src/main/scala/org/apache/spark/deploy/RRunner.scala | 3 +-- 1 file changed, 1 insertion(+), 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 index 1561aad34e174..31c92294edbcc 100644 --- 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") {