blob: 77706679615cd0e2d37049a4d1a5c0fce448ab5d [file] [log] [blame]
diff --git a/r/src/main/scala/org/apache/spark/api/r/RBackendHelper.scala b/r/src/main/scala/org/apache/spark/api/r/RBackendHelper.scala
index 9c1eb38d5..155f645dc 100644
--- a/r/src/main/scala/org/apache/spark/api/r/RBackendHelper.scala
+++ b/r/src/main/scala/org/apache/spark/api/r/RBackendHelper.scala
@@ -30,7 +30,7 @@ class RBackendHelper(val backend : RBackend) {
var port : Int = 0
def init() : Int = {
- port = backend.init()
+ port = backend.init()._1
port
}
@@ -81,4 +81,4 @@ Its for testing purposes and should never be called
def apply() : RBackendHelper = new RBackendHelper(new RBackend())
-}
\ No newline at end of file
+}
diff --git a/spark/pom.xml b/spark/pom.xml
index 2211efd87..db5b58cf4 100644
--- a/spark/pom.xml
+++ b/spark/pom.xml
@@ -45,8 +45,8 @@
<plugin.shade.version>2.4.1</plugin.shade.version>
<plugin.scala.version>2.15.2</plugin.scala.version>
<!-- spark versions -->
- <spark.version>2.2.0</spark.version>
- <py4j.version>0.10.4</py4j.version>
+ <spark.version>2.4.5</spark.version>
+ <py4j.version>0.10.7</py4j.version>
<spark.archive>spark-${spark.version}</spark.archive>
<spark.src.download.url>
diff --git a/spark/scala-2.10/src/main/scala/org/apache/zeppelin/spark/SparkScala210Interpreter.scala b/spark/scala-2.10/src/main/scala/org/apache/zeppelin/spark/SparkScala210Interpreter.scala
index 995ee1539..e712c7d73 100644
--- a/spark/scala-2.10/src/main/scala/org/apache/zeppelin/spark/SparkScala210Interpreter.scala
+++ b/spark/scala-2.10/src/main/scala/org/apache/zeppelin/spark/SparkScala210Interpreter.scala
@@ -67,7 +67,8 @@ class SparkScala210Interpreter(override val conf: SparkConf,
settings.embeddedDefaults(Thread.currentThread().getContextClassLoader())
settings.usejavacp.value = true
settings.classpath.value = getUserJars.mkString(File.pathSeparator)
- sparkILoop = new SparkILoop(null, new JPrintWriter(Console.out, true))
+ // ZEPPELIN-3324: Fix ambiguous reference to overloaded definition
+ sparkILoop = new SparkILoop()
if (printReplOutput) {
Console.setOut(interpreterOutput)
}
diff --git a/spark/spark1-shims/pom.xml b/spark/spark1-shims/pom.xml
index 797c461e4..6bc18e6e2 100644
--- a/spark/spark1-shims/pom.xml
+++ b/spark/spark1-shims/pom.xml
@@ -50,7 +50,7 @@
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-core_${scala.binary.version}</artifactId>
- <version>${spark.version}</version>
+ <version>2.2.3</version>
<scope>provided</scope>
</dependency>
@@ -79,4 +79,4 @@
</plugins>
</build>
-</project>
\ No newline at end of file
+</project>