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