Skip to content

Commit 57abca3

Browse files
author
Andrew Or
committed
Move comment back into if case
1 parent 574fb1e commit 57abca3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1046,9 +1046,9 @@ class DAGScheduler(
10461046

10471047
clearCacheLocs()
10481048

1049-
// Some tasks had failed; let's resubmit this shuffleStage
1050-
// TODO: Lower-level scheduler should also deal with this
10511049
if (shuffleStage.outputLocs.contains(Nil)) {
1050+
// Some tasks had failed; let's resubmit this shuffleStage
1051+
// TODO: Lower-level scheduler should also deal with this
10521052
logInfo("Resubmitting " + shuffleStage + " (" + shuffleStage.name +
10531053
") because some of its tasks had failed: " +
10541054
shuffleStage.outputLocs.zipWithIndex.filter(_._1.isEmpty)

0 commit comments

Comments
 (0)