Fixed spark.addJar for R.

apache · Mar 3, 2017 · 031b648 · 031b648
1 parent fe16bcb
commit 031b648
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/R/pkg/R/context.R b/R/pkg/R/context.R
@@ -341,7 +341,8 @@ spark.addFile <- function(path, recursive = FALSE) {
 spark.addJar <- function(path, addToCurrentClassLoader = FALSE) {
   sc <- getSparkContext()
   normalizedPath <- suppressWarnings(normalizePath(path))
-  invisible(callJMethod(sc, "addJar", normalizedPath, addToCurrentClassLoader))
+  scala_sc = callJMethod(sc, "sc")
+  invisible(callJMethod(scala_sc, "addJar", normalizedPath, addToCurrentClassLoader))
 }