Skip to content
Snippets Groups Projects
Commit 14972141 authored by Matei Zaharia's avatar Matei Zaharia
Browse files

Merge pull request #344 from mbautin/log_preferred_hosts

Log preferred hosts
parents d0bae072 4725b0f6
No related branches found
No related tags found
No related merge requests found
...@@ -201,7 +201,8 @@ private[spark] class TaskSetManager( ...@@ -201,7 +201,8 @@ private[spark] class TaskSetManager(
val taskId = sched.newTaskId() val taskId = sched.newTaskId()
// Figure out whether this should count as a preferred launch // Figure out whether this should count as a preferred launch
val preferred = isPreferredLocation(task, host) 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( logInfo("Starting task %s:%d as TID %s on slave %s: %s (%s)".format(
taskSet.id, index, taskId, slaveId, host, prefStr)) taskSet.id, index, taskId, slaveId, host, prefStr))
// Do various bookkeeping // Do various bookkeeping
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment