diff --git a/core/pom.xml b/core/pom.xml
index bd6767e03bb9..8c23842730e3 100644
--- a/core/pom.xml
+++ b/core/pom.xml
@@ -244,6 +244,11 @@
easymockclassextension
test
+
+ asm
+ asm
+ test
+
com.novocode
junit-interface
diff --git a/core/src/test/java/org/apache/spark/JavaAPISuite.java b/core/src/test/java/org/apache/spark/JavaAPISuite.java
index e46298c6a9e6..a84d2a2e289a 100644
--- a/core/src/test/java/org/apache/spark/JavaAPISuite.java
+++ b/core/src/test/java/org/apache/spark/JavaAPISuite.java
@@ -18,6 +18,7 @@
package org.apache.spark;
import java.io.*;
+import java.net.URI;
import java.util.*;
import scala.Tuple2;
@@ -705,7 +706,7 @@ public void textFiles() throws IOException {
}
@Test
- public void wholeTextFiles() throws IOException {
+ public void wholeTextFiles() throws Exception {
byte[] content1 = "spark is easy to use.\n".getBytes("utf-8");
byte[] content2 = "spark is also easy to use.\n".getBytes("utf-8");
@@ -721,7 +722,7 @@ public void wholeTextFiles() throws IOException {
List> result = readRDD.collect();
for (Tuple2 res : result) {
- Assert.assertEquals(res._2(), container.get(res._1()));
+ Assert.assertEquals(res._2(), container.get(new URI(res._1()).getPath()));
}
}
diff --git a/pom.xml b/pom.xml
index 0d46bb4114f7..05f76d566e9d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -468,6 +468,13 @@
3.1
test
+
+
+ asm
+ asm
+ 3.3.1
+ test
+
org.mockito
mockito-all
diff --git a/project/SparkBuild.scala b/project/SparkBuild.scala
index 7bb39dc77120..55a2aa0fc714 100644
--- a/project/SparkBuild.scala
+++ b/project/SparkBuild.scala
@@ -293,7 +293,9 @@ object SparkBuild extends Build {
"com.novocode" % "junit-interface" % "0.10" % "test",
"org.easymock" % "easymockclassextension" % "3.1" % "test",
"org.mockito" % "mockito-all" % "1.9.0" % "test",
- "junit" % "junit" % "4.10" % "test"
+ "junit" % "junit" % "4.10" % "test",
+ // Needed by cglib which is needed by easymock.
+ "asm" % "asm" % "3.3.1" % "test"
),
testOptions += Tests.Argument(TestFrameworks.JUnit, "-v", "-a"),
@@ -461,7 +463,7 @@ object SparkBuild extends Build {
def toolsSettings = sharedSettings ++ Seq(
name := "spark-tools",
- libraryDependencies <+= scalaVersion(v => "org.scala-lang" % "scala-compiler" % v ),
+ libraryDependencies <+= scalaVersion(v => "org.scala-lang" % "scala-compiler" % v),
libraryDependencies <+= scalaVersion(v => "org.scala-lang" % "scala-reflect" % v )
) ++ assemblySettings ++ extraAssemblySettings
@@ -630,9 +632,9 @@ object SparkBuild extends Build {
scalaVersion := "2.10.4",
retrieveManaged := true,
retrievePattern := "[type]s/[artifact](-[revision])(-[classifier]).[ext]",
- libraryDependencies := Seq("spark-streaming-mqtt", "spark-streaming-zeromq",
+ libraryDependencies := Seq("spark-streaming-mqtt", "spark-streaming-zeromq",
"spark-streaming-flume", "spark-streaming-kafka", "spark-streaming-twitter",
- "spark-streaming", "spark-mllib", "spark-bagel", "spark-graphx",
+ "spark-streaming", "spark-mllib", "spark-bagel", "spark-graphx",
"spark-core").map(sparkPreviousArtifact(_).get intransitive())
)