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 61d220b commit c3d0f61Copy full SHA for c3d0f61
core/src/main/scala/org/apache/spark/storage/memory/MemoryStore.scala
@@ -354,7 +354,7 @@ private[spark] class MemoryStore(
354
// Synchronize so that transfer is atomic
355
memoryManager.synchronized {
356
releaseUnrollMemoryForThisTask(unrollMemoryUsedByThisBlock)
357
- val success = memoryManager.acquireStorageMemory(blockId, entry.size)
+ val success = memoryManager.acquireStorageMemory(blockId, entry.size, MemoryMode.ON_HEAP)
358
assert(success, "transferring unroll memory to storage memory failed")
359
}
360
entries.synchronized {
0 commit comments