ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Just update typo and comments

Browse source
This commit is contained in:
Andrew xia 2013-03-23 07:25:30 +08:00
parent 5892393140
commit d1d9bdaabe
2 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
core/src/main/scala/spark/scheduler/cluster/Pool.scala
View file

@ -5,8 +5,7 @@ import scala.collection.mutable.ArrayBuffer
import spark.Logging
import spark.scheduler.cluster.SchedulingMode.SchedulingMode
/**
* An interface for
*
* An Schedulable entity that represent collection of TaskSetManager
*/
private[spark] class Pool(val poolName: String, schedulingMode: SchedulingMode,val minShare:Int, val weight:Int) extends Schedulable with Logging {

4
core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala
View file

@ -28,7 +28,7 @@ private[spark] class TaskSetManager(sched: ClusterScheduler, val taskSet: TaskSe
// Maximum times a task is allowed to fail before failing the job
val MAX_TASK_FAILURES = 4
val TASKSET_MINIMIUM_SHARES = 1
val TASKSET_MINIMUM_SHARES = 1
val TASKSET_WEIGHT = 1
// Quantile of tasks at which to start speculation
@ -102,7 +102,7 @@ private[spark] class TaskSetManager(sched: ClusterScheduler, val taskSet: TaskSe
override def getMinShare(): Int =
{
return TASKSET_MINIMIUM_SHARES
return TASKSET_MINIMUM_SHARES
}
override def getRunningTasks(): Int =