Skip to content

Commit fb3acfc

Browse files
committed
fix log msg
1 parent e01b7aa commit fb3acfc

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
@@ -1142,8 +1142,8 @@ class DAGScheduler(
11421142
s"due to a fetch failure from $mapStage (${mapStage.name})")
11431143
markStageAsFinished(failedStage, Some(failureMessage))
11441144
} else {
1145-
logInfo(s"Ignoring fetch failure from $task as it's from $failedStage, " +
1146-
s"which is no longer running")
1145+
logDebug(s"Received fetch failure from $task, but its from $failedStage which is no " +
1146+
s"longer running")
11471147
}
11481148

11491149
if (disallowStageRetryForTest) {

0 commit comments

Comments
 (0)