Skip to content

Commit

Permalink
see my shocked face..........
Browse files Browse the repository at this point in the history
  • Loading branch information
CodingCat committed Aug 4, 2014
1 parent f600085 commit 941a4fd
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ private[spark] class TaskSetManager(
// but at host level.
private val pendingTasksForHost = new HashMap[String, ArrayBuffer[Int]]

private var hasNodeLocalOnlyTasks = true
private var hasNodeLocalOnlyTasks = false

// Set of pending tasks for each rack -- similar to the above.
private val pendingTasksForRack = new HashMap[String, ArrayBuffer[Int]]
Expand Down Expand Up @@ -416,7 +416,7 @@ private[spark] class TaskSetManager(

var allowedLocality = maxLocality

if (maxLocality != TaskLocality.NO_PREF) {// } || hasNodeLocalOnlyTasks) {
if (maxLocality != TaskLocality.NO_PREF || hasNodeLocalOnlyTasks) {
allowedLocality = getAllowedLocalityLevel(curTime)
if (allowedLocality > maxLocality) {
// We're not allowed to search for farther-away tasks
Expand Down

0 comments on commit 941a4fd

Please sign in to comment.