diff options
| author | trueyao <501663994@qq.com> | 2016-03-17 09:45:06 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-03-17 09:45:06 +0000 |
| commit | ea9ca6f04ce1fb83612f907d6d0996d6fb362bd2 (patch) | |
| tree | 13e2f5471c8675815acbd0dcc891958100089f0c /core/src/main/scala | |
| parent | 357d82d84d6372debd28da6ad0a2ee904957a7fe (diff) | |
| download | spark-ea9ca6f04ce1fb83612f907d6d0996d6fb362bd2.tar.gz spark-ea9ca6f04ce1fb83612f907d6d0996d6fb362bd2.tar.bz2 spark-ea9ca6f04ce1fb83612f907d6d0996d6fb362bd2.zip | |
[SPARK-13901][CORE] correct the logDebug information when jump to the next locality level
JIRA Issue:https://issues.apache.org/jira/browse/SPARK-13901
In getAllowedLocalityLevel method of TaskSetManager,we get wrong logDebug information when jump to the next locality level.So we should fix it.
Author: trueyao <501663994@qq.com>
Closes #11719 from trueyao/logDebug-localityWait.
Diffstat (limited to 'core/src/main/scala')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala index f1339d530a..ffd5f5d20a 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala @@ -555,9 +555,9 @@ private[spark] class TaskSetManager( // Jump to the next locality level, and reset lastLaunchTime so that the next locality // wait timer doesn't immediately expire lastLaunchTime += localityWaits(currentLocalityIndex) - currentLocalityIndex += 1 - logDebug(s"Moving to ${myLocalityLevels(currentLocalityIndex)} after waiting for " + + logDebug(s"Moving to ${myLocalityLevels(currentLocalityIndex + 1)} after waiting for " + s"${localityWaits(currentLocalityIndex)}ms") + currentLocalityIndex += 1 } else { return myLocalityLevels(currentLocalityIndex) } |