From ea9ca6f04ce1fb83612f907d6d0996d6fb362bd2 Mon Sep 17 00:00:00 2001
From: trueyao <501663994@qq.com>
Date: Thu, 17 Mar 2016 09:45:06 +0000
Subject: [PATCH] [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.
---
.../scala/org/apache/spark/scheduler/TaskSetManager.scala | 4 ++--
1 file 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)
}
--
GitLab