We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4470fa1 commit 6bc23afCopy full SHA for 6bc23af
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1130,7 +1130,8 @@ class DAGScheduler(
1130
1131
if (failedStage.latestInfo.attemptId != task.stageAttemptId) {
1132
logInfo(s"Ignoring fetch failure from $task as it's from $failedStage attempt" +
1133
- s" ${task.stageAttemptId}, which has already failed")
+ s" ${task.stageAttemptId} and there is a more recent attempt for that stage " +
1134
+ s"(attempt ID ${failedStage.latestInfo.attemptId}) running")
1135
} else {
1136
1137
// It is likely that we receive multiple FetchFailed for a single stage (because we have
0 commit comments