File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
core/src/main/scala/org/apache/spark/storage Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -464,12 +464,12 @@ final class ShuffleBlockFetcherIterator(
464464 val cachedDirsByExec = hostLocalDirManager.getCachedHostLocalDirs()
465465 val (hostLocalBlocksWithCachedDirs, hostLocalBlocksWithMissingDirs) =
466466 hostLocalBlocksByExecutor
467- .map { case (hostLocalBmId, bmInfos ) =>
468- (hostLocalBmId, bmInfos , cachedDirsByExec.get(hostLocalBmId.executorId))
467+ .map { case (hostLocalBmId, blockInfos ) =>
468+ (hostLocalBmId, blockInfos , cachedDirsByExec.get(hostLocalBmId.executorId))
469469 }.partition(_._3.isDefined)
470470 val immutableHostLocalBlocksWithoutDirs =
471- hostLocalBlocksWithMissingDirs.map { case (hostLocalBmId, bmInfos , _) =>
472- hostLocalBmId -> bmInfos
471+ hostLocalBlocksWithMissingDirs.map { case (hostLocalBmId, blockInfos , _) =>
472+ hostLocalBmId -> blockInfos
473473 }.toMap
474474 if (immutableHostLocalBlocksWithoutDirs.nonEmpty) {
475475 logDebug(s " Asynchronous fetching host-local blocks without cached executors' dir: " +
You can’t perform that action at this time.
0 commit comments