From d91e5ed340e518d8f30454ee39e89e7f658fe508 Mon Sep 17 00:00:00 2001 From: "Zhang, Liye" Date: Wed, 6 May 2015 13:18:28 +0800 Subject: [PATCH] change kb to mb --- .../scala/org/apache/spark/serializer/KryoSerializer.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 b7bc087855b9f..48cd3f6c1392b 100644 --- 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