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 31fe08e commit 40fe1d7Copy full SHA for 40fe1d7
core/src/main/scala/org/apache/spark/CacheManager.scala
@@ -73,7 +73,7 @@ private[spark] class CacheManager(blockManager: BlockManager) extends Logging {
73
if (context.runningLocally) { return computedValues }
74
if (storageLevel.useDisk && !storageLevel.useMemory) {
75
blockManager.put(key, computedValues, storageLevel, tellMaster = true)
76
- return blockManager.get(key) match {
+ return blockManager.get(key) match {
77
case Some(values) =>
78
return new InterruptibleIterator(context, values.asInstanceOf[Iterator[T]])
79
case None =>
0 commit comments