Skip to content

Commit 453bd21

Browse files
committed
Bug fix
1 parent 4094df6 commit 453bd21

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/parquet/ParquetTableOperations.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,7 @@ private[parquet] class FilteringParquetRowInputFormat
330330
val toFetch = new ArrayList[FileStatus]
331331
footerCache.synchronized {
332332
for (status <- statuses) {
333-
if (!footerCache.contains(status)) {
333+
if (footerCache.contains(status)) {
334334
footers.add(footerCache(status))
335335
} else {
336336
footers.add(null)
@@ -348,7 +348,7 @@ private[parquet] class FilteringParquetRowInputFormat
348348
var i = 0
349349
var j = 0
350350
while (i < toFetch.size) {
351-
while (statuses(j) ne toFetch.get(i)) {
351+
while (statuses.get(j) ne toFetch.get(i)) {
352352
j += 1
353353
}
354354
footers(j) = fetched(i)

0 commit comments

Comments
 (0)