Use maxMemory to better estimate memory available for BlockManager cache

2012-08-02 12:05:05 -07:00 · 2012-08-02 12:05:05 -07:00 · 6790908b11
parent b980eabd86
commit 6790908b11
1 changed files with 1 additions and 1 deletions
--- a/core/src/main/scala/spark/storage/BlockManager.scala
+++ b/core/src/main/scala/spark/storage/BlockManager.scala
@ -580,6 +580,6 @@ class BlockManager(val master: BlockManagerMaster, val serializer: Serializer, m
 object BlockManager {
  def getMaxMemoryFromSystemProperties(): Long = {
    val memoryFraction = System.getProperty("spark.storage.memoryFraction", "0.66").toDouble
-    (Runtime.getRuntime.totalMemory * memoryFraction).toLong
+    (Runtime.getRuntime.maxMemory * memoryFraction).toLong
  }
 }