jerrypeng commented on code in PR #57286:
URL: https://github.com/apache/spark/pull/57286#discussion_r3593285936
##########
core/src/main/scala/org/apache/spark/shuffle/streaming/StreamingShuffleManager.scala:
##########
@@ -118,11 +120,9 @@ private[spark] class StreamingShuffleManager extends
ShuffleManager with Logging
true
}
- override def shuffleBlockResolver: ShuffleBlockResolver = {
- // don't need to support this for the streaming shuffle implementation
- // since block manager is not used
- throw new UnsupportedOperationException()
- }
+ // No shuffleBlockResolver: a StreamingShuffleManager is a PipelinedShuffle,
serving its output
Review Comment:
remove this comment
--
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]
