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

[SPARK-32920][CORE][FOLLOW-UP] Fix string interpolator in the log

Browse source 
### What changes were proposed in this pull request?

fix string interpolator

### Why are the changes needed?

To log the correct stage info.

### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

Pass existed tests.

Closes #33738 from Ngone51/fix.

Authored-by: yi.wu <yi.wu@databricks.com>
Signed-off-by: Hyukjin Kwon <gurwls223@apache.org>
This commit is contained in:
yi.wu 2021-08-13 21:44:22 +09:00 committed by Hyukjin Kwon
parent ec5f3a17e3
commit a47ceaf549
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -1311,7 +1311,7 @@ private[spark] class DAGScheduler(
s"${stage.shuffleDep.getMergerLocs.map(_.host).mkString(", ")}") s"${stage.shuffleDep.getMergerLocs.map(_.host).mkString(", ")}")
} else { } else {
stage.shuffleDep.setShuffleMergeEnabled(false) stage.shuffleDep.setShuffleMergeEnabled(false)
logInfo("Push-based shuffle disabled for $stage (${stage.name})") logInfo(s"Push-based shuffle disabled for $stage (${stage.name})")
} }
} }
} }