Skip to content

Commit 7c829cb

Browse files
author
Anselme Vignon
committed
bugfix, hopefully correct this time
1 parent 005a7f8 commit 7c829cb

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -150,9 +150,9 @@ case class ParquetTableScan(
150150
// Parquet will leave partitioning columns empty, so we fill them in here.
151151
var i = 0
152152
while (i < requestedPartitionOrdinals.size) {
153-
row (requestedPartitionOrdinals (i)._2) =
154-
partitionRowValues (requestedPartitionOrdinals (i)._1)
155-
i += 1
153+
row (requestedPartitionOrdinals (i)._2) =
154+
partitionRowValues (requestedPartitionOrdinals (i)._1)
155+
i += 1
156156
}
157157
row
158158
}
@@ -164,6 +164,7 @@ case class ParquetTableScan(
164164
.update(
165165
requestedPartitionOrdinals (i)._2,
166166
partitionRowValues (requestedPartitionOrdinals (i)._1))
167+
i += 1
167168
}
168169
Row.fromSeq(rVals)
169170
}

0 commit comments

Comments
 (0)