diff options
| author | Reynold Xin <rxin@cs.berkeley.edu> | 2012-12-21 15:49:33 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@cs.berkeley.edu> | 2012-12-21 15:49:33 -0800 |
| commit | 60f7338092ad0c3a608c0e466f66047a508a35be (patch) | |
| tree | c071f2b504cd7199055914324d82a0a6917163ec /core | |
| parent | 3334b7c6b5e26620dcc0e03ec0d5108165e1679e (diff) | |
| download | spark-60f7338092ad0c3a608c0e466f66047a508a35be.tar.gz spark-60f7338092ad0c3a608c0e466f66047a508a35be.tar.bz2 spark-60f7338092ad0c3a608c0e466f66047a508a35be.zip | |
Remove the call to close input stream in 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 f24196ea49..93d7327324 100644 --- a/core/src/main/scala/spark/KryoSerializer.scala +++ b/core/src/main/scala/spark/KryoSerializer.scala @@ -46,8 +46,8 @@ class KryoDeserializationStream(kryo: Kryo, inStream: InputStream) extends Deser } def close() { + // Kryo's Input automatically closes the input stream it is using. input.close() - inStream.close() } } |