From 60f7338092ad0c3a608c0e466f66047a508a35be Mon Sep 17 00:00:00 2001 From: Reynold Xin Date: Fri, 21 Dec 2012 15:49:33 -0800 Subject: Remove the call to close input stream in Kryo serializer. --- core/src/main/scala/spark/KryoSerializer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'core') 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() } } -- cgit v1.2.3