Github user gczsjdy commented on a diff in the pull request: https://github.com/apache/spark/pull/19788#discussion_r153117088 --- Diff: core/src/main/scala/org/apache/spark/storage/BlockId.scala --- @@ -116,8 +117,8 @@ object BlockId { def apply(name: String): BlockId = name match { case RDD(rddId, splitIndex) => RDDBlockId(rddId.toInt, splitIndex.toInt) - case SHUFFLE(shuffleId, mapId, reduceId) => - ShuffleBlockId(shuffleId.toInt, mapId.toInt, reduceId.toInt) + case SHUFFLE(shuffleId, mapId, reduceId, n) => --- End diff -- :nit length?
--- --------------------------------------------------------------------- To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands, e-mail: reviews-h...@spark.apache.org