Fixing numeric typo

mccheah · mccheah · commit 1d6d1be9ef33 · 2015-03-26T20:39:29.000-07: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
@@ -61,7 +61,7 @@ class KryoSerializer(conf: SparkConf)
     throw new IllegalArgumentException("spark.kryoserializer.buffer.max.mb must be less than " +
       s"2048 mb, got: + $maxBufferSizeMb mb.")
   }
-  private val maxBufferSize = maxBufferSizeMb * 1026 * 1024
+  private val maxBufferSize = maxBufferSizeMb * 1024 * 1024
 
   private val referenceTracking = conf.getBoolean("spark.kryo.referenceTracking", true)
   private val registrationRequired = conf.getBoolean("spark.kryo.registrationRequired", false)

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ class KryoSerializer(conf: SparkConf)`
`61`	`61`	`throw new IllegalArgumentException("spark.kryoserializer.buffer.max.mb must be less than " +`
`62`	`62`	`s"2048 mb, got: + $maxBufferSizeMb mb.")`
`63`	`63`	`}`
`64`		`- private val maxBufferSize = maxBufferSizeMb * 1026 * 1024`
	`64`	`+ private val maxBufferSize = maxBufferSizeMb * 1024 * 1024`
`65`	`65`
`66`	`66`	`private val referenceTracking = conf.getBoolean("spark.kryo.referenceTracking", true)`
`67`	`67`	`private val registrationRequired = conf.getBoolean("spark.kryo.registrationRequired", false)`