Skip to content

Commit

Permalink
Fix another indentation
Browse files Browse the repository at this point in the history
  • Loading branch information
Hieu Huynh authored and Hieu Huynh committed Jul 16, 2018
1 parent b2affd2 commit 20a032c
Showing 1 changed file with 4 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1377,7 +1377,8 @@ class TaskSetManagerSuite extends SparkFunSuite with LocalSparkContext with Logg
sched = new FakeTaskScheduler(sc, ("exec1", "host1"),
("exec2", "host2"), ("exec3", "host3"))
sched.initialize(new FakeSchedulerBackend() {
override def killTask(taskId: Long,
override def killTask(
taskId: Long,
executorId: String,
interruptThread: Boolean,
reason: String): Unit = {
Expand All @@ -1395,7 +1396,8 @@ class TaskSetManagerSuite extends SparkFunSuite with LocalSparkContext with Logg
// so that the test can check that task is resubmitted correctly
var resubmittedTasks = new mutable.HashSet[Int]
val dagScheduler = new FakeDAGScheduler(sc, sched) {
override def taskEnded(task: Task[_],
override def taskEnded(
task: Task[_],
reason: TaskEndReason,
result: Any,
accumUpdates: Seq[AccumulatorV2[_, _]],
Expand Down

0 comments on commit 20a032c

Please sign in to comment.