Skip to content

Commit

Permalink
overloooked cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
squito committed Jun 20, 2016
1 parent 64ab7fb commit 3edb6fe
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -286,7 +286,6 @@ private[spark] class TaskSchedulerImpl(
return launchedTask
}


/**
* Called by cluster manager to offer resources on slaves. We respond by asking our active task
* sets for tasks in order of priority. We fill each node with tasks in a round-robin manner so
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -575,7 +575,6 @@ private[spark] class TaskSetManager(
index
}


/**
* Check whether the given task set has been blacklisted to the point that it can't run anywhere.
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,12 +96,6 @@ class TaskSchedulerImplSuite extends SparkFunSuite with LocalSparkContext with B
test("Scheduler correctly accounts for multiple CPUs per task") {
val taskCpus = 2
val taskScheduler = setupScheduler("spark.task.cpus" -> taskCpus.toString)
taskScheduler.initialize(new FakeSchedulerBackend)
// Need to initialize a DAGScheduler for the taskScheduler to use for callbacks.
new DAGScheduler(sc, taskScheduler) {
override def taskStarted(task: Task[_], taskInfo: TaskInfo) {}
override def executorAdded(execId: String, host: String) {}
}
// Give zero core offers. Should not generate any tasks
val zeroCoreWorkerOffers = Seq(new WorkerOffer("executor0", "host0", 0),
new WorkerOffer("executor1", "host1", 0))
Expand Down

0 comments on commit 3edb6fe

Please sign in to comment.