Fixed bad method reference in SparkR runner
diff --git a/sparkr-interpreter/src/main/resources/kernelR/sparkr_runner.R b/sparkr-interpreter/src/main/resources/kernelR/sparkr_runner.R
index fbf2881..a76aa06 100644
--- a/sparkr-interpreter/src/main/resources/kernelR/sparkr_runner.R
+++ b/sparkr-interpreter/src/main/resources/kernelR/sparkr_runner.R
@@ -30,11 +30,6 @@
script.basename <- dirname(script.name)
setwd(script.basename)
-# TODO: Use this library instead of the forked SparkR once they either
-# a) allow us to connect and use an existing Spark Context
-# b) allow us to have access to the .sparkREnv to do our own work
-#
-# and provide access in some form to the methods used to access the JVM
# Add the SparkR library to our list
.libPaths(c(file.path(Sys.getenv("SPARK_HOME"), "R", "lib"), .libPaths()))
library(SparkR)
@@ -45,7 +40,7 @@
rm(".sparkRcon", envir = .sparkREnv)
sparkR.connect <- function() {
- if (connExists(.sparkREnv)) {
+ if (SparkR:::connExists(.sparkREnv)) {
print("Connection to SparkR backend has already been established!")
return()
}
