Skip to content

Commit 640b2c8

Browse files
author
madianjun
committed
[CORE][MINOR] Correct a log message
1 parent a9ae262 commit 640b2c8

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
@@ -1521,8 +1521,8 @@ private[spark] class DAGScheduler(
15211521
markStageAsFinished(failedStage, errorMessage = Some(failureMessage),
15221522
willRetry = !shouldAbortStage)
15231523
} else {
1524-
logDebug(s"Received fetch failure from $task, but its from $failedStage which is no " +
1525-
s"longer running")
1524+
logDebug(s"Received fetch failure from $task, but it's from $failedStage which is no " +
1525+
"longer running")
15261526
}
15271527

15281528
if (mapStage.rdd.isBarrier()) {

0 commit comments

Comments
 (0)