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 2960c93 commit 1332156Copy full SHA for 1332156
core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -519,7 +519,8 @@ private[spark] class BlockManager(
519
val locations = Random.shuffle(master.getLocations(blockId))
520
for (loc <- locations) {
521
logDebug(s"Getting remote block $blockId from $loc")
522
- val data = blockTransferService.fetchBlockSync(loc.host, loc.port, blockId.toString).nioByteBuffer()
+ val data = blockTransferService.fetchBlockSync(
523
+ loc.host, loc.port, blockId.toString).nioByteBuffer()
524
525
if (data != null) {
526
if (asBlockResult) {
0 commit comments