File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
core/src/main/scala/org/apache/spark/deploy Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -40,8 +40,6 @@ import org.apache.spark.util.RedirectThread
40
40
* subprocess and then has it connect back to the JVM to access system properties etc.
41
41
*/
42
42
object RRunner extends CondaRunner with Logging {
43
- val sparkRBackend = new RBackend ()
44
-
45
43
override def run (args : Array [String ], maybeConda : Option [CondaEnvironment ]): Unit = {
46
44
val rFile = PythonRunner .formatPath(args(0 ))
47
45
@@ -86,6 +84,7 @@ object RRunner extends CondaRunner with Logging {
86
84
87
85
// Launch a SparkR backend server for the R process to connect to; this will let it see our
88
86
// Java system properties etc.
87
+ val sparkRBackend = new RBackend ()
89
88
@ volatile var sparkRBackendPort = 0
90
89
val initialized = new Semaphore (0 )
91
90
val sparkRBackendThread = new Thread (" SparkR backend" ) {
You can’t perform that action at this time.
0 commit comments