diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-06-07 22:39:06 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-06-07 22:39:06 -0700 |
| commit | 1ae60bcb3673118c9838ecc6afac1d015fe79def (patch) | |
| tree | 615ef01bcdf8d5a7ef142f20e05af7ea5ed0a272 /core/src/test/scala | |
| parent | fff3728552ccd2fc02fc4b7b750a9e3698869718 (diff) | |
| parent | 606bb1b450064a2b909e4275ce45325dbbef4eca (diff) | |
| download | spark-1ae60bcb3673118c9838ecc6afac1d015fe79def.tar.gz spark-1ae60bcb3673118c9838ecc6afac1d015fe79def.tar.bz2 spark-1ae60bcb3673118c9838ecc6afac1d015fe79def.zip | |
Merge pull request #634 from xiajunluan/master
[Spark-753] Fix ClusterSchedulSuite unit test failed
Diffstat (limited to 'core/src/test/scala')
| -rw-r--r-- | core/src/test/scala/spark/scheduler/ClusterSchedulerSuite.scala | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/core/src/test/scala/spark/scheduler/ClusterSchedulerSuite.scala b/core/src/test/scala/spark/scheduler/ClusterSchedulerSuite.scala index a39418b716..c861597c6b 100644 --- a/core/src/test/scala/spark/scheduler/ClusterSchedulerSuite.scala +++ b/core/src/test/scala/spark/scheduler/ClusterSchedulerSuite.scala @@ -88,7 +88,7 @@ class DummyTask(stageId: Int) extends Task[Int](stageId) } } -class ClusterSchedulerSuite extends FunSuite with LocalSparkContext { +class ClusterSchedulerSuite extends FunSuite with LocalSparkContext with Logging { def createDummyTaskSetManager(priority: Int, stage: Int, numTasks: Int, cs: ClusterScheduler, taskSet: TaskSet): DummyTaskSetManager = { new DummyTaskSetManager(priority, stage, numTasks, cs , taskSet) @@ -96,8 +96,11 @@ class ClusterSchedulerSuite extends FunSuite with LocalSparkContext { def resourceOffer(rootPool: Pool): Int = { val taskSetQueue = rootPool.getSortedTaskSetQueue() - for (taskSet <- taskSetQueue) - { + /* Just for Test*/ + for (manager <- taskSetQueue) { + logInfo("parentName:%s, parent running tasks:%d, name:%s,runningTasks:%d".format(manager.parent.name, manager.parent.runningTasks, manager.name, manager.runningTasks)) + } + for (taskSet <- taskSetQueue) { taskSet.slaveOffer("execId_1", "hostname_1", 1) match { case Some(task) => return taskSet.stageId |