Skip to content

Commit c835ccb

Browse files
madianjunHyukjinKwon
authored andcommitted
[CORE][MINOR] Correct a log message in DAGScheduler
### What changes were proposed in this pull request? Correct a word in a log message. ### Why are the changes needed? Log message will be more clearly. ### Does this PR introduce any user-facing change? No. ### How was this patch tested? Test is not needed. Closes #25880 from mdianjun/fix-a-word. Authored-by: madianjun <[email protected]> Signed-off-by: HyukjinKwon <[email protected]> (cherry picked from commit e2c4787) Signed-off-by: HyukjinKwon <[email protected]>
1 parent 1b939ea commit c835ccb

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
@@ -1452,8 +1452,8 @@ private[spark] class DAGScheduler(
14521452
markStageAsFinished(failedStage, errorMessage = Some(failureMessage),
14531453
willRetry = !shouldAbortStage)
14541454
} else {
1455-
logDebug(s"Received fetch failure from $task, but its from $failedStage which is no " +
1456-
s"longer running")
1455+
logDebug(s"Received fetch failure from $task, but it's from $failedStage which is no " +
1456+
"longer running")
14571457
}
14581458

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

0 commit comments

Comments
 (0)