Update BlockManager.scala

wangfei · wangfei · commit dff1f0fd2678 · 2014-05-10T09:03:52.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala
@@ -1045,7 +1045,7 @@ private[spark] object BlockManager extends Logging {
 
   def getMaxMemory(conf: SparkConf): Long = {
     val memoryFraction = conf.getDouble("spark.storage.memoryFraction", 0.6)
-    if (memoryFraction > 1 && memoryFraction <= 0) {
+    if (memoryFraction > 1 && memoryFraction < 0) {
       throw new Exception("spark.storage.memoryFraction should be between 0 and 1.")
     }
     (Runtime.getRuntime.maxMemory * memoryFraction).toLong

Original file line number	Diff line number	Diff line change
`@@ -1045,7 +1045,7 @@ private[spark] object BlockManager extends Logging {`
`1045`	`1045`
`1046`	`1046`	`def getMaxMemory(conf: SparkConf): Long = {`
`1047`	`1047`	`val memoryFraction = conf.getDouble("spark.storage.memoryFraction", 0.6)`
`1048`		`- if (memoryFraction > 1 && memoryFraction <= 0) {`
	`1048`	`+ if (memoryFraction > 1 && memoryFraction < 0) {`
`1049`	`1049`	`throw new Exception("spark.storage.memoryFraction should be between 0 and 1.")`
`1050`	`1050`	`}`
`1051`	`1051`	`(Runtime.getRuntime.maxMemory * memoryFraction).toLong`