ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[CORE][MINOR] Correct a log message in DAGScheduler

Browse source 
### 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 <madianjun@jd.com>
Signed-off-by: HyukjinKwon <gurwls223@apache.org>
This commit is contained in:
madianjun 2019-09-22 17:22:37 +09:00 committed by HyukjinKwon
parent 89bad267d4
commit e2c47876e9
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
View file

@ -1521,8 +1521,8 @@ private[spark] class DAGScheduler(
markStageAsFinished(failedStage, errorMessage = Some(failureMessage),
willRetry = !shouldAbortStage)
} else {
logDebug(s"Received fetch failure from $task, but its from $failedStage which is no " +
s"longer running")
logDebug(s"Received fetch failure from $task, but it's from $failedStage which is no " +
"longer running")
}
if (mapStage.rdd.isBarrier()) {