This is an automated email from the ASF dual-hosted git repository. gurwls223 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push: new f54ecd68e776 [SPARK-46601][CORE] Fix log error in handleStatusMessage f54ecd68e776 is described below commit f54ecd68e776ded7e318e990eb0746021a4f58d2 Author: jiaoqingbo <1178404...@qq.com> AuthorDate: Mon Jan 8 17:36:20 2024 +0900 [SPARK-46601][CORE] Fix log error in handleStatusMessage ### What changes were proposed in this pull request? Fix log error in handleStatusMessage ### Why are the changes needed? When needMergeOutput is true, map/merge should be output instead of map The code got the location of both wrong ### Does this PR introduce _any_ user-facing change? NO ### How was this patch tested? PASS GA ### Was this patch authored or co-authored using generative AI tooling? Closes #44606 from jiaoqingbo/46601. Authored-by: jiaoqingbo <1178404...@qq.com> Signed-off-by: Hyukjin Kwon <gurwls...@apache.org> --- core/src/main/scala/org/apache/spark/MapOutputTracker.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/MapOutputTracker.scala b/core/src/main/scala/org/apache/spark/MapOutputTracker.scala index 851ecfc662e4..ed590a67522c 100644 --- a/core/src/main/scala/org/apache/spark/MapOutputTracker.scala +++ b/core/src/main/scala/org/apache/spark/MapOutputTracker.scala @@ -744,7 +744,7 @@ private[spark] class MapOutputTrackerMaster( needMergeOutput: Boolean): Unit = { val hostPort = context.senderAddress.hostPort val shuffleStatus = shuffleStatuses.get(shuffleId).head - logDebug(s"Handling request to send ${if (needMergeOutput) "map" else "map/merge"}" + + logDebug(s"Handling request to send ${if (needMergeOutput) "map/merge" else "map"}" + s" output locations for shuffle $shuffleId to $hostPort") if (needMergeOutput) { context.reply( --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org