You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by gu...@apache.org on 2019/09/22 08:23:44 UTC

[spark] branch branch-2.4 updated: [CORE][MINOR] Correct a log message in DAGScheduler

This is an automated email from the ASF dual-hosted git repository.

gurwls223 pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/branch-2.4 by this push:
     new c835ccb  [CORE][MINOR] Correct a log message in DAGScheduler
c835ccb is described below

commit c835ccb268cabeb1144dce5c26a9dfcead953edb
Author: madianjun <ma...@jd.com>
AuthorDate: Sun Sep 22 17:22:37 2019 +0900

    [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 <ma...@jd.com>
    Signed-off-by: HyukjinKwon <gu...@apache.org>
    (cherry picked from commit e2c47876e9bd7faacb196baf517f549d58391002)
    Signed-off-by: HyukjinKwon <gu...@apache.org>
---
 core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
index 0ba8343..5be3c40 100644
--- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
+++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1452,8 +1452,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()) {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org