Skip to content

Commit d780ed8

Browse files
nonglirxin
authored andcommitted
[SPARK-13533][SQL] Fix readBytes in VectorizedPlainValuesReader
## What changes were proposed in this pull request? Fix readBytes in VectorizedPlainValuesReader. This fixes a copy and paste issue. ## How was this patch tested? Ran ParquetHadoopFsRelationSuite which failed before this. Author: Nong Li <[email protected]> Closes #11414 from nongli/spark-13533.
1 parent 3814d0b commit d780ed8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedPlainValuesReader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ public final void readBytes(int total, ColumnVector c, int rowId) {
8585
for (int i = 0; i < total; i++) {
8686
// Bytes are stored as a 4-byte little endian int. Just read the first byte.
8787
// TODO: consider pushing this in ColumnVector by adding a readBytes with a stride.
88-
c.putInt(rowId + i, buffer[offset]);
88+
c.putByte(rowId + i, buffer[offset]);
8989
offset += 4;
9090
}
9191
}

0 commit comments

Comments
 (0)