diff options
| author | Mosharaf Chowdhury <mosharaf@cs.berkeley.edu> | 2013-10-14 14:50:49 -0700 |
|---|---|---|
| committer | Mosharaf Chowdhury <mosharaf@cs.berkeley.edu> | 2013-10-16 21:33:33 -0700 |
| commit | feb45d391f8d09c120d7d43e72e96e9bf9784fa0 (patch) | |
| tree | 6c0464b06ee4f1854593c6985b931f172a364a62 /core | |
| parent | 6e5a60fab46daf5525749d9e71f1ccfaffddd34d (diff) | |
| download | spark-feb45d391f8d09c120d7d43e72e96e9bf9784fa0.tar.gz spark-feb45d391f8d09c120d7d43e72e96e9bf9784fa0.tar.bz2 spark-feb45d391f8d09c120d7d43e72e96e9bf9784fa0.zip | |
Default blockSize is 4MB.
BroadcastTest2 example added for testing broadcasts.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala b/core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala index 29e0dd26d4..c174804e9a 100644 --- a/core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala +++ b/core/src/main/scala/org/apache/spark/broadcast/TorrentBroadcast.scala @@ -179,7 +179,7 @@ extends Logging { initialized = false } - val BlockSize = System.getProperty("spark.broadcast.blockSize", "2048").toInt * 1024 + val BlockSize = System.getProperty("spark.broadcast.blockSize", "4096").toInt * 1024 def blockifyObject[IN](obj: IN): TorrentInfo = { val byteArray = Utils.serialize[IN](obj) |