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 56f71cd commit 95c7f67Copy full SHA for 95c7f67
1 file changed
core/src/main/scala/org/apache/spark/CacheManager.scala
@@ -71,7 +71,7 @@ private[spark] class CacheManager(blockManager: BlockManager) extends Logging {
71
val computedValues = rdd.computeOrReadCheckpoint(split, context)
72
// Persist the result, so long as the task is not running locally
73
if (context.runningLocally) { return computedValues }
74
- if (storageLevel == StorageLevel.DISK_ONLY || storageLevel == StorageLevel.DISK_ONLY_2) {
+ if (storageLevel.useDisk || !storageLevel.useMemory) {
75
blockManager.put(key, computedValues, storageLevel, tellMaster = true)
76
return blockManager.get(key) match {
77
case Some(values) =>
0 commit comments