From 653bc73790c0633b98bb2556bc177befc8b96db0 Mon Sep 17 00:00:00 2001 From: Nong Li Date: Sat, 27 Feb 2016 17:48:49 -0800 Subject: [PATCH] [SPARK-13533][SQL] Fix readBytes in VectorizedPlainValuesReader --- .../datasources/parquet/VectorizedPlainValuesReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedPlainValuesReader.java b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedPlainValuesReader.java index bf3283e85329b..57cc28e9f4e05 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedPlainValuesReader.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedPlainValuesReader.java @@ -85,7 +85,7 @@ public final void readBytes(int total, ColumnVector c, int rowId) { for (int i = 0; i < total; i++) { // Bytes are stored as a 4-byte little endian int. Just read the first byte. // TODO: consider pushing this in ColumnVector by adding a readBytes with a stride. - c.putInt(rowId + i, buffer[offset]); + c.putByte(rowId + i, buffer[offset]); offset += 4; } }