We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d988e7f commit b2da4c5Copy full SHA for b2da4c5
core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -657,7 +657,6 @@ private[spark] class BlockManager(
657
blockId: BlockId,
658
level: StorageLevel,
659
classTag: ClassTag[_]): StreamCallbackWithID = {
660
- // Delegate shuffle blocks here to resolver if supported
661
if (blockId.isShuffle || blockId.isInternalShuffle) {
662
logInfo(s"Putting shuffle block ${blockId}")
663
try {
0 commit comments