diff --git a/repl/src/main/scala/org/apache/livy/repl/SparkRInterpreter.scala b/repl/src/main/scala/org/apache/livy/repl/SparkRInterpreter.scala index c74c8c8..120323a 100644 --- a/repl/src/main/scala/org/apache/livy/repl/SparkRInterpreter.scala +++ b/repl/src/main/scala/org/apache/livy/repl/SparkRInterpreter.scala @@ -199,6 +199,7 @@ class SparkRInterpreter( sendRequest("""assign(".scStartTime", as.integer(Sys.time()), envir = SparkR:::.sparkREnv)""") sendRequest("""assign(".sc", SparkR:::callJStatic("org.apache.livy.repl.SparkRInterpreter", "getSparkContext"), envir = SparkR:::.sparkREnv)""") + sendRequest("""assign(".sparkRjsc", get(".sc", envir = SparkR:::.sparkREnv), envir = SparkR:::.sparkREnv)""") sendRequest("""assign("sc", get(".sc", envir = SparkR:::.sparkREnv), envir=.GlobalEnv)""") if (sparkMajorVersion >= 2) {