update log msg

markhamstra · Jul 17, 2015 · 6bc23af · 6bc23af
1 parent 4470fa1
commit 6bc23af
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1130,7 +1130,8 @@ class DAGScheduler(
 
         if (failedStage.latestInfo.attemptId != task.stageAttemptId) {
           logInfo(s"Ignoring fetch failure from $task as it's from $failedStage attempt" +
-            s" ${task.stageAttemptId}, which has already failed")
+            s" ${task.stageAttemptId} and there is a more recent attempt for that stage " +
+            s"(attempt ID ${failedStage.latestInfo.attemptId}) running")
         } else {
 
           // It is likely that we receive multiple FetchFailed for a single stage (because we have