Github user yucai commented on a diff in the pull request: https://github.com/apache/spark/pull/19788#discussion_r153049650 --- Diff: core/src/main/scala/org/apache/spark/shuffle/IndexShuffleBlockResolver.scala --- @@ -196,12 +196,14 @@ private[spark] class IndexShuffleBlockResolver( override def getBlockData(blockId: ShuffleBlockId): ManagedBuffer = { // The block is actually going to be a range of a single map output file for this map, so // find out the consolidated file, then the offset within that from our index + logDebug(s"Fetch block data for $blockId") --- End diff -- Without this info, it looks hard to know continuous shuffle block read really happen, and I found `getLocalBytes` had similar debug info also. ``` logDebug(s"Getting local block $blockId as bytes") ``` How about keeping it?
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org