File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
core/src/main/scala/org/apache/spark/serializer Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -49,19 +49,19 @@ class KryoSerializer(conf: SparkConf)
4949 with Logging
5050 with Serializable {
5151
52- private val bufferSizeMb : Double = conf.getDouble(" spark.kryoserializer.buffer.mb" , 0.064 )
52+ private val bufferSizeMb = conf.getDouble(" spark.kryoserializer.buffer.mb" , 0.064 )
5353 if (bufferSizeMb >= 2048 ) {
5454 throw new IllegalArgumentException (" spark.kryoserializer.buffer.mb must be less than " +
5555 s " 2048 mb, got: + $bufferSizeMb mb. " )
5656 }
5757 private val bufferSize = (bufferSizeMb * 1024 * 1024 ).toInt
5858
59- val maxBufferSizeMb : Int = conf.getInt(" spark.kryoserializer.buffer.max.mb" , 64 )
59+ val maxBufferSizeMb = conf.getInt(" spark.kryoserializer.buffer.max.mb" , 64 )
6060 if (maxBufferSizeMb >= 2048 ) {
6161 throw new IllegalArgumentException (" spark.kryoserializer.buffer.max.mb must be less than " +
6262 s " 2048 mb, got: + $maxBufferSizeMb mb. " )
6363 }
64- private val maxBufferSize = maxBufferSizeMb * 1024 * 1024
64+ private val maxBufferSize = maxBufferSizeMb * 1026 * 1024
6565
6666 private val referenceTracking = conf.getBoolean(" spark.kryo.referenceTracking" , true )
6767 private val registrationRequired = conf.getBoolean(" spark.kryo.registrationRequired" , false )
You can’t perform that action at this time.
0 commit comments