diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala index e7226a63793a0..ca3f04b973479 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -1108,8 +1108,8 @@ class DAGScheduler( } else { // It is likely that we receive multiple FetchFailed for a single stage (because we have - // multiple tasks running concurrently on different executors). In that case, it is possible - // the fetch failure has already been handled by the scheduler. + // multiple tasks running concurrently on different executors). In that case, it is + // possible the fetch failure has already been handled by the scheduler. if (runningStages.contains(failedStage)) { logInfo(s"Marking $failedStage (${failedStage.name}) as failed " + s"due to a fetch failure from $mapStage (${mapStage.name})") diff --git a/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala index 6232bb652f861..090352c3d8b95 100644 --- a/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala +++ b/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala @@ -611,15 +611,16 @@ class DAGSchedulerSuite sc.listenerBus.waitUntilEmpty(WAIT_TIMEOUT_MILLIS) assert(countSubmittedMapStageAttempts() === 2) - // NOTE: the actual ResubmitFailedStages may get called at any time during this, shouldn't effect anything -- - // our calling it just makes *SURE* it gets called between the desired event and our check. - + // NOTE: the actual ResubmitFailedStages may get called at any time during this, shouldn't + // effect anything -- our calling it just makes *SURE* it gets called between the desired event + // and our check. } /** This tests the case where a late FetchFailed comes in after the map stage has finished getting * retried and a new reduce stage starts running. */ - test("extremely late fetch failures don't cause multiple concurrent attempts for the same stage") { + test("extremely late fetch failures don't cause multiple concurrent attempts for " + + "the same stage") { val shuffleMapRdd = new MyRDD(sc, 2, Nil) val shuffleDep = new ShuffleDependency(shuffleMapRdd, null) val shuffleId = shuffleDep.shuffleId