change kb to mb

liyezhang556520 · liyezhang556520 · commit d91e5ed340e5 · 2015-05-06T13:18:28.000+08:00
diff --git a/core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala b/core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala
@@ -51,9 +51,9 @@ class KryoSerializer(conf: SparkConf)
 
   private val bufferSizeKb = conf.getSizeAsKb("spark.kryoserializer.buffer", "64k")
   
-  if (bufferSizeKb >= 2048) {
+  if (bufferSizeKb >= 2048 * 1024) {
     throw new IllegalArgumentException("spark.kryoserializer.buffer must be less than " +
-      s"2048 mb, got: + $bufferSizeKb mb.")
+      s"2048 mb, got: + ${bufferSizeKb/1024} mb.")
   }
   private val bufferSize = (bufferSizeKb * 1024).toInt
 

Original file line number	Diff line number	Diff line change
`@@ -51,9 +51,9 @@ class KryoSerializer(conf: SparkConf)`
`51`	`51`
`52`	`52`	`private val bufferSizeKb = conf.getSizeAsKb("spark.kryoserializer.buffer", "64k")`
`53`	`53`
`54`		`- if (bufferSizeKb >= 2048) {`
	`54`	`+ if (bufferSizeKb >= 2048 * 1024) {`
`55`	`55`	`throw new IllegalArgumentException("spark.kryoserializer.buffer must be less than " +`
`56`		`- s"2048 mb, got: + $bufferSizeKb mb.")`
	`56`	`+ s"2048 mb, got: + ${bufferSizeKb/1024} mb.")`
`57`	`57`	`}`
`58`	`58`	`private val bufferSize = (bufferSizeKb * 1024).toInt`
`59`	`59`