File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
core/src/main/scala/org/apache/spark/scheduler Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -216,7 +216,7 @@ private[spark] class TaskSchedulerImpl(
216
216
// Mark all the existing TaskSetManagers of this stage as zombie, as we are adding a new one.
217
217
// This is necessary to handle a corner case. Let's say a stage has 10 partitions and has 2
218
218
// TaskSetManagers: TSM1(zombie) and TSM2(active). TSM1 has a running task for partition 10
219
- // and it completes. TSM2 finishes tasks for partition 1-19 , and thinks he is still active
219
+ // and it completes. TSM2 finishes tasks for partition 1-9 , and thinks he is still active
220
220
// because partition 10 is not completed yet. However, DAGScheduler gets task completion
221
221
// events for all the 10 partitions and thinks the stage is finished. If it's a shuffle stage
222
222
// and somehow it has missing map outputs, then DAGScheduler will resubmit it and create a
You can’t perform that action at this time.
0 commit comments