Skip to content

Commit

Permalink
fix scala tyle
Browse files Browse the repository at this point in the history
  • Loading branch information
Thomas Graves committed Jan 27, 2016
1 parent 574000d commit 249fc78
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -991,7 +991,7 @@ class DAGSchedulerSuite extends SparkFunSuite with LocalSparkContext with Timeou
test("late task events posted") {
val baseRdd = new MyRDD(sc, 4, Nil)
val finalRdd = new MyRDD(sc, 4, List(new OneToOneDependency(baseRdd)))
submit(finalRdd, Array(0,1,2,3))
submit(finalRdd, Array(0, 1, 2, 3))

// complete two tasks
runEvent(makeCompletionEvent(
Expand All @@ -1002,7 +1002,7 @@ class DAGSchedulerSuite extends SparkFunSuite with LocalSparkContext with Timeou
Seq.empty[AccumulableInfo], createFakeTaskInfoWithId(1)))
sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS)
// verify stage exists
assert(scheduler.stageIdToStage.contains(0))
assert(scheduler.stageIdToStage.contains(0))
assert(sparkListener.endedTasks.size == 2)

// finish other 2 tasks
Expand All @@ -1016,7 +1016,7 @@ class DAGSchedulerSuite extends SparkFunSuite with LocalSparkContext with Timeou
assert(sparkListener.endedTasks.size == 4)

// verify the stage is done
assert(!scheduler.stageIdToStage.contains(0))
assert(!scheduler.stageIdToStage.contains(0))

// stage should be complete finish one other Successful task to simulate what can happen
// with a speculative task and make sure the event is sent out
Expand Down

0 comments on commit 249fc78

Please sign in to comment.