Skip to content

Commit

Permalink
change default for spark.kryoserializer.buffer.max.mb to 64mb and add…
Browse files Browse the repository at this point in the history
… some documentation
  • Loading branch information
koertkuipers committed Jun 21, 2014
1 parent 1bcc22c commit 15f6d81
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ class KryoSerializer(conf: SparkConf)
with Serializable {

private val bufferSize = conf.getInt("spark.kryoserializer.buffer.mb", 2) * 1024 * 1024
private val maxBufferSize = conf.getInt("spark.kryoserializer.buffer.max.mb", 16) * 1024 * 1024
private val maxBufferSize = conf.getInt("spark.kryoserializer.buffer.max.mb", 64) * 1024 * 1024
private val referenceTracking = conf.getBoolean("spark.kryo.referenceTracking", true)
private val registrator = conf.getOption("spark.kryo.registrator")

Expand Down
15 changes: 11 additions & 4 deletions docs/configuration.md
Original file line number Diff line number Diff line change
Expand Up @@ -385,10 +385,17 @@ Apart from these, the following properties are also available, and may be useful
<td><code>spark.kryoserializer.buffer.mb</code></td>
<td>2</td>
<td>
Maximum object size to allow within Kryo (the library needs to create a buffer at least as
large as the largest single object you'll serialize). Increase this if you get a "buffer limit
exceeded" exception inside Kryo. Note that there will be one buffer <i>per core</i> on each
worker.
Object size to allow within Kryo using default (pre-allocated) buffers (the library needs to create
a buffer at least as large as the largest single object you'll serialize). Note that there will be
one buffer <i>per core</i> on each worker.
</td>
</tr>
<tr>
<td><code>spark.kryoserializer.buffer.max.mb</code></td>
<td>64</td>
<td>
Maximum object size to allow within Kryo by resizing buffers as needed (which has some overhead).
Increase this if you get a "buffer limit exceeded" exception inside Kryo.
</td>
</tr>
</table>
Expand Down

0 comments on commit 15f6d81

Please sign in to comment.