diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2011-07-09 18:08:07 -0400 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2011-07-09 18:08:07 -0400 |
| commit | 003480f374b3c47cedc40d8e14d5744057aa5fef (patch) | |
| tree | 321bc9d01173c7da521d8fc3229edc8a0070e728 /core | |
| parent | aea5cb4413eb9f99ca174a789ab5d9e1c62a60ad (diff) | |
| download | spark-003480f374b3c47cedc40d8e14d5744057aa5fef.tar.gz spark-003480f374b3c47cedc40d8e14d5744057aa5fef.tar.bz2 spark-003480f374b3c47cedc40d8e14d5744057aa5fef.zip | |
Register byte[] with Kryo serializer
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/spark/KryoSerializer.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/KryoSerializer.scala b/core/src/main/scala/spark/KryoSerializer.scala index 658b7b7d0f..6528297350 100644 --- a/core/src/main/scala/spark/KryoSerializer.scala +++ b/core/src/main/scala/spark/KryoSerializer.scala @@ -132,7 +132,7 @@ class KryoSerializer extends Serializer with Logging { val toRegister: Seq[AnyRef] = Seq( // Arrays Array(1), Array(1.0), Array(1.0f), Array(1L), Array(""), Array(("", "")), - Array(new java.lang.Object), + Array(new java.lang.Object), Array(1.toByte), // Specialized Tuple2s ("", ""), (1, 1), (1.0, 1.0), (1L, 1L), (1, 1.0), (1.0, 1), (1L, 1.0), (1.0, 1L), (1, 1L), (1L, 1), |