Skip to content

Commit 5ec97d7

Browse files
committed
Add SqlNewHadoopRDD.unsetInputFileName() that I accidentally deleted.
1 parent ae46cf4 commit 5ec97d7

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

core/src/main/scala/org/apache/spark/rdd/SqlNewHadoopRDD.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -190,6 +190,7 @@ private[spark] class SqlNewHadoopRDD[V: ClassTag](
190190

191191
private def close() {
192192
if (reader != null) {
193+
SqlNewHadoopRDD.unsetInputFileName()
193194
// Close the reader and release it. Note: it's very important that we don't close the
194195
// reader more than once, since that exposes us to MAPREDUCE-5918 when running against
195196
// Hadoop 1.x and older Hadoop 2.x releases. That bug can lead to non-deterministic

0 commit comments

Comments
 (0)