Fixed dagscheduler suite because of a logging message change.

2013-10-11 16:18:22 -07:00 · 2013-10-11 16:18:22 -07:00 · 97ffebbe87
parent a61cf40ab9
commit 97ffebbe87
1 changed files with 1 additions and 1 deletions
--- a/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
@ -250,7 +250,7 @@ class DAGSchedulerSuite extends FunSuite with BeforeAndAfter with LocalSparkCont
  test("trivial job failure") {
    submit(makeRdd(1, Nil), Array(0))
    failed(taskSets(0), "some failure")
-    assert(failure.getMessage === "Job failed: some failure")
+    assert(failure.getMessage === "Job aborted: some failure")
  }

  test("run trivial shuffle") {