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 4282a71 commit 5615d1cCopy full SHA for 5615d1c
core/src/main/scala/org/apache/spark/memory/MemoryManager.scala
@@ -58,7 +58,8 @@ private[spark] abstract class MemoryManager(
58
onHeapStorageMemoryPool.incrementPoolSize(onHeapStorageMemory)
59
onHeapExecutionMemoryPool.incrementPoolSize(onHeapExecutionMemory)
60
61
- protected[this] val maxOffHeapMemory = if (conf.get(MEMORY_OFFHEAP_ENABLED)) conf.get(MEMORY_OFFHEAP_SIZE) else 0
+ protected[this] val maxOffHeapMemory =
62
+ if (conf.get(MEMORY_OFFHEAP_ENABLED)) conf.get(MEMORY_OFFHEAP_SIZE) else 0
63
protected[this] val offHeapStorageMemory =
64
(maxOffHeapMemory * conf.get(MEMORY_STORAGE_FRACTION)).toLong
65
0 commit comments