File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
sql/core/src/main/scala/org/apache/spark/sql/parquet Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff 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 }
You can’t perform that action at this time.
0 commit comments