diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-08 22:26:34 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-01-08 22:26:34 -0800 |
| commit | 14972141f998d36344ac16cfe9949e702db41762 (patch) | |
| tree | 13f982755f97aafeb772230228c5fcef20aa96e9 | |
| parent | d0bae072eac528a343617f0a2eaa85d05d8040a9 (diff) | |
| parent | 4725b0f6439337c7a0f5f6fc7034c6f6b9488ae9 (diff) | |
| download | spark-14972141f998d36344ac16cfe9949e702db41762.tar.gz spark-14972141f998d36344ac16cfe9949e702db41762.tar.bz2 spark-14972141f998d36344ac16cfe9949e702db41762.zip | |
Merge pull request #344 from mbautin/log_preferred_hosts
Log preferred hosts
| -rw-r--r-- | core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala | 3 |
1 files changed, 2 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..a842afcdeb 100644 --- a/core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala +++ b/core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala @@ -201,7 +201,8 @@ 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 |