Close record readers in HadoopFile after finishing a split

This commit is contained in:
Matei Zaharia 2011-02-10 11:20:51 -08:00
Родитель 62f1c6f5a8
Коммит dc24aecd8f
1 изменённых файлов: 3 добавлений и 0 удалений

Просмотреть файл

@ -76,6 +76,9 @@ extends RDD[(K, V)](sc) {
} }
gotNext = true gotNext = true
} }
if (finished) {
reader.close()
}
!finished !finished
} }