venkata91 commented on a change in pull request #34122:
URL: https://github.com/apache/spark/pull/34122#discussion_r792329758
##########
File path: core/src/main/scala/org/apache/spark/MapOutputTracker.scala
##########
@@ -1213,10 +1273,10 @@ private[spark] class MapOutputTrackerWorker(conf:
SparkConf) extends MapOutputTr
useMergeResult: Boolean): MapSizesByExecutorId = {
logDebug(s"Fetching outputs for shuffle $shuffleId")
val (mapOutputStatuses, mergedOutputStatuses) = getStatuses(shuffleId,
conf,
- // EnableBatchFetch can be set to false during stage retry when the
- // shuffleDependency.shuffleMergeEnabled is set to false, and Driver
+ // enableBatchFetch can be set to false during stage retry when the
Review comment:
Fixed earlier usages of `shuffleMergeEnabled` appropriately and some
minor typos.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
