@@ -4,6 +4,7 @@ assemblyJarName <- "sparkr-assembly-0.1.jar"
44
55sparkR.onLoad <- function (libname , pkgname ) {
66 assemblyJarPath <- paste(libname , " /SparkR/" , assemblyJarName , sep = " " )
7+ assemblyJarPath <- gsub(" " , " \\ " , assemblyJarPath , fixed = T )
78 packageStartupMessage(" [SparkR] Initializing with classpath " , assemblyJarPath , " \n " )
89
910 sparkMem <- Sys.getenv(" SPARK_MEM" , " 512m" )
@@ -67,16 +68,19 @@ sparkR.init <- function(
6768 }
6869
6970 .jaddClassPath(sparkJars )
70- jars = c(as.character(.sparkREnv $ assemblyJarPath ), as.character(sparkJars ))
71-
71+ jars <- c(as.character(.sparkREnv $ assemblyJarPath ), as.character(sparkJars ))
72+
73+ nonEmptyJars <- Filter(function (x ) { x != " " }, jars )
74+ localJarPaths <- sapply(nonEmptyJars , function (j ) { paste(" file://" , j , sep = " " ) })
75+
7276 assign(
7377 " .sparkRjsc" ,
7478 J(" edu.berkeley.cs.amplab.sparkr.RRDD" ,
7579 " createSparkContext" ,
7680 master ,
7781 appName ,
7882 as.character(sparkHome ),
79- .jarray(jars , " java/lang/String" ),
83+ .jarray(localJarPaths , " java/lang/String" ),
8084 sparkEnvirMap ,
8185 sparkExecutorEnvMap ),
8286 envir = .sparkREnv
0 commit comments