diff --git a/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala b/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala index 404da6a6f86a819982388418b1470d729ca29511..36e711d2a2392ea9788a1f7faee7ec0af2884085 100644 --- a/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala +++ b/core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala @@ -474,7 +474,7 @@ private[spark] class MemoryStore( val bxi_iterator = blockManager.inMemBlockExInfo.iterator() while (freedMemory < space && bxi_iterator.hasNext) { val bxi = iterator.next() - if (blockIsEvictable(bxi.blockId,entries( + if (blockIsEvictable(bxi.blockId,entries(bxi.blockId))) { blockManager.stageExInfos.get(blockManager.currentStage) match { case Some(curStageExInfo) => // cur is this stage's output RDD