Bug fix

xiliu82 · Aug 18, 2014 · dae8efe · dae8efe
1 parent c71e9ed
commit dae8efe
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetTableOperations.scala b/sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetTableOperations.scala
@@ -353,10 +353,10 @@ private[parquet] class FilteringParquetRowInputFormat
         val newFooters = new mutable.HashMap[FileStatus, Footer]
         if (toFetch.size > 0) {
           val fetched = getFooters(conf, toFetch)
-          for ((footer, i) <- fetched.zipWithIndex) {
-            newFooters(statuses.get(i)) = footer
-            footerCache.putAll(newFooters)
+          for ((status, i) <- toFetch.zipWithIndex) {
+            newFooters(status) = fetched.get(i)
           }
+          footerCache.putAll(newFooters)
         }
         footers = new ArrayList[Footer](statuses.size)
         for (status <- statuses) {