Skip to content

Commit

Permalink
undo some un-intentional changes
Browse files Browse the repository at this point in the history
  • Loading branch information
squito committed Sep 26, 2016
1 parent 27b4bde commit 278fff3
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 6 deletions.
Expand Up @@ -139,6 +139,4 @@ private[scheduler] class TaskSetBlacklist(val conf: SparkConf, val stageId: Int,
}
}
}


}
Expand Up @@ -648,7 +648,6 @@ class BasicSchedulerIntegrationSuite extends SchedulerIntegrationSuite[SingleCor
assertDataStructuresEmpty(noFailure = false)
}


def testNoBlacklist(name: String)(body: => Unit): Unit = {
// in these simple tests, we only have one executor, so it doens't make sense to turn on the
// blacklist. Just an artifact of this simple test-framework still kinda acting like local-mode
Expand Down
Expand Up @@ -114,9 +114,7 @@ class FakeTaskScheduler(sc: SparkContext, liveExecutors: (String, String)* /* ex
}
}

override def taskSetFinished(manager: TaskSetManager): Unit = {
finishedManagers += manager
}
override def taskSetFinished(manager: TaskSetManager): Unit = finishedManagers += manager

override def isExecutorAlive(execId: String): Boolean = executors.contains(execId)

Expand Down

0 comments on commit 278fff3

Please sign in to comment.