diff options
| author | Mikhail Bautin <mbautin@gmail.com> | 2012-12-26 15:52:51 -0800 |
|---|---|---|
| committer | Mikhail Bautin <mbautin@gmail.com> | 2013-01-07 20:06:09 -0800 |
| commit | c41042c816c2d6299aa7d93529b7c39db5d5c03a (patch) | |
| tree | 9a63ca339d5a62febb48c0b7e6c7caa3245b6890 | |
| parent | a37adfa67bac51b2630c6e1673f8607a87273402 (diff) | |
| download | spark-c41042c816c2d6299aa7d93529b7c39db5d5c03a.tar.gz spark-c41042c816c2d6299aa7d93529b7c39db5d5c03a.tar.bz2 spark-c41042c816c2d6299aa7d93529b7c39db5d5c03a.zip | |
Log preferred hosts
| -rw-r--r-- | core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala b/core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala index cf4aae03a7..dda7a6c64a 100644 --- a/core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala +++ b/core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala @@ -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 |