Skip to content

Commit 776269f

Browse files
authored
Update TaskSchedulerImpl.scala
1 parent 15c0489 commit 776269f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -332,7 +332,7 @@ private[spark] class TaskSchedulerImpl(
332332
taskIdToTaskSetManager.get(tid) match {
333333
case Some(taskSet) =>
334334
if (state == TaskState.LOST) {
335-
// TaskState.LOST is only used by the deprecated Mesos fine-grained scheduling mode,
335+
// TaskState.LOST is only used by the Mesos fine-grained scheduling mode,
336336
// where each executor corresponds to a single task, so mark the executor as failed.
337337
val execId = taskIdToExecutorId.getOrElse(tid, throw new IllegalStateException(
338338
"taskIdToTaskSetManager.contains(tid) <=> taskIdToExecutorId.contains(tid)"))

0 commit comments

Comments
 (0)