Skip to content

Commit c8f3ac6

Browse files
Ngone51squito
authored andcommitted
[SPARK-23888][CORE] correct the comment of hasAttemptOnHost()
TaskSetManager.hasAttemptOnHost had a misleading comment. The comment said that it only checked for running tasks, but really it checked for any tasks that might have run in the past as well. This updates to line up with the implementation. Author: wuyi <ngone_5451@163.com> Closes #20998 from Ngone51/SPARK-23888.
1 parent e82cb68 commit c8f3ac6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -287,7 +287,7 @@ private[spark] class TaskSetManager(
287287
None
288288
}
289289

290-
/** Check whether a task is currently running an attempt on a given host */
290+
/** Check whether a task once ran an attempt on a given host */
291291
private def hasAttemptOnHost(taskIndex: Int, host: String): Boolean = {
292292
taskAttempts(taskIndex).exists(_.host == host)
293293
}

0 commit comments

Comments
 (0)