diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java index 1b8b18d4d8735..4b2c9325941c8 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedColumnReader.java @@ -615,7 +615,7 @@ private void readBinaryBatch(int rowId, int num, WritableColumnVector column) th VectorizedValuesReader data = (VectorizedValuesReader) dataColumn; if (column.dataType() == DataTypes.StringType || column.dataType() == DataTypes.BinaryType || DecimalType.isByteArrayDecimalType(column.dataType())) { - defColumn.readBinarys(num, column, rowId, maxDefLevel, data); + defColumn.readBinaries(num, column, rowId, maxDefLevel, data); } else if (column.dataType() == DataTypes.TimestampType) { final boolean failIfRebase = "EXCEPTION".equals(int96RebaseMode); if (!shouldConvertTimestamps()) { diff --git a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java index 03595068f0d31..d6600206d66d2 100644 --- a/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java +++ b/sql/core/src/main/java/org/apache/spark/sql/execution/datasources/parquet/VectorizedRleValuesReader.java @@ -486,7 +486,7 @@ public void readDoubles( } } - public void readBinarys( + public void readBinaries( int total, WritableColumnVector c, int rowId,