We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f6fdff1 commit 5fdd0e2Copy full SHA for 5fdd0e2
core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
@@ -290,7 +290,7 @@ class DAGSchedulerSuite extends FunSuite with BeforeAndAfter with LocalSparkCont
290
val rdd = makeRdd(1, Nil)
291
val jobId = submit(rdd, Array(0))
292
cancel(jobId)
293
- assert(failure.getMessage === s"Job $jobId cancelled")
+ assert(failure.getMessage === s"Job $jobId cancelled ")
294
assert(sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS))
295
assert(sparkListener.failedStages.contains(0))
296
assert(sparkListener.failedStages.size === 1)
0 commit comments