diff --git a/core/src/main/scala/spark/HadoopFile.scala b/core/src/main/scala/spark/HadoopFile.scala index a63c9d8a94d90be5fe36fc2316472c316e1bc208..629dcc7da53e59a240f6f2cd0ab5ae59d0a51b83 100644 --- a/core/src/main/scala/spark/HadoopFile.scala +++ b/core/src/main/scala/spark/HadoopFile.scala @@ -76,6 +76,9 @@ extends RDD[(K, V)](sc) { } gotNext = true } + if (finished) { + reader.close() + } !finished }