From 1d6d1be9ef335c51b477d8c2f661a72cd1c82f73 Mon Sep 17 00:00:00 2001 From: mcheah Date: Thu, 26 Mar 2015 20:39:29 -0700 Subject: [PATCH] Fixing numeric typo --- .../main/scala/org/apache/spark/serializer/KryoSerializer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala b/core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala index f52ba7d715179..579fb6624e692 100644 --- 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)