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

Log preferred hosts

Browse source
This commit is contained in:
Mikhail Bautin 2012-12-26 15:52:51 -08:00
parent a37adfa67b
commit c41042c816
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -201,7 +201,9 @@ private[spark] class TaskSetManager(
val taskId = sched.newTaskId()
// Figure out whether this should count as a preferred launch
val preferred = isPreferredLocation(task, host)
val prefStr = if (preferred) "preferred" else "non-preferred"
val prefStr = if (preferred) "preferred" else
"non-preferred, not one of " +
task.preferredLocations.mkString(", ")
logInfo("Starting task %s:%d as TID %s on slave %s: %s (%s)".format(
taskSet.id, index, taskId, slaveId, host, prefStr))
// Do various bookkeeping