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 e01b7aa commit fb3acfcCopy full SHA for fb3acfc
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1142,8 +1142,8 @@ class DAGScheduler(
1142
s"due to a fetch failure from $mapStage (${mapStage.name})")
1143
markStageAsFinished(failedStage, Some(failureMessage))
1144
} else {
1145
- logInfo(s"Ignoring fetch failure from $task as it's from $failedStage, " +
1146
- s"which is no longer running")
+ logDebug(s"Received fetch failure from $task, but its from $failedStage which is no " +
+ s"longer running")
1147
}
1148
1149
if (disallowStageRetryForTest) {
0 commit comments