apache / apache/parquet-java

[parquet-java] Intermittent out-of-bounds dictionary ID when reading dictionary-encoded Parquet pages

Abierto
#3,715 0 comentarios 0 reacciones 0 asignados Ver en GitHub
Type: bug
Lenguaje dominante
Java
Estrellas
3.1k
Forks
1.6k
Merge medio
3 d 12 h
PR fusionados (30 d)
33

Descripción

### Describe the bug, including details regarding any error messages, version, and platform.

## Description

We intermittently encounter a `ParquetDecodingException` when reading Parquet files written by Apache Hudi with Spark.

The issue cannot be reproduced consistently for every write, but it has occurred repeatedly across different write jobs.

The failures have a similar call chain: while reading a dictionary-encoded data page, parquet-java decodes a dictionary ID that is outside the range of the current dictionary. `PlainValuesDictionary` then attempts to access the dictionary array with that ID and throws an `ArrayIndexOutOfBoundsException`.

In the representative case below, the affected column is:

```text
optional int32 chan_second_cate_cd
```

The dictionary contains 13 entries, so the valid dictionary IDs are `0` through `12`. However, the data page produces dictionary ID `14`, resulting in:

```text
java.lang.ArrayIndexOutOfBoundsException: Index 14 out of bounds for length 13
```

This failure occurs in row group `0`, at column value `292293` out of `478848`, and at value `12293` out of `20000` in the current data page.

The value `14` is an internal Parquet dictionary ID, not the actual value stored in the column.

## Environment

| Component | Version |
| --- | --- |
| Apache Hudi | `0.13.1` |
| Write engine | Apache Spark `3.4` |
| parquet-mr | `1.12.3` |

## Representative Stack Trace

Click to expand

```text
org.apache.parquet.io.ParquetDecodingException: Can not read value at 292293 in block 0 in file
at org.apache.parquet.hadoop.InternalParquetRecordReader.nextKeyValue(InternalParquetRecordReader.java:264)
at org.apache.parquet.hadoop.ParquetRecordReader.nextKeyValue(ParquetRecordReader.java:207)
at org.apache.spark.sql.execution.datasources.RecordReaderIterator.hasNext(RecordReaderIterator.scala:39)
at org.apache.spark.sql.execution.datasources.RecordReaderIterator$$anon$1.hasNext(RecordReaderIterator.scala:61)
at org.apache.spark.sql.execution.datasources.FileScanRDD$$anon$1.hasNext(FileScanRDD.scala:125)
at scala.collection.Iterator$$anon$10.hasNext(Iterator.scala:460)
at org.apache.spark.sql.catalyst.expressions.GeneratedClass$GeneratedIteratorForCodegenStage1.processNext(Unknown Source)
at org.apache.spark.sql.execution.BufferedRowIterator.hasNext(BufferedRowIterator.java:43)
at org.apache.spark.sql.execution.WholeStageCodegenExec$$anon$1.hasNext(WholeStageCodegenExec.scala:760)
at org.apache.spark.shuffle.sort.BypassMergeSortShuffleWriter.write(BypassMergeSortShuffleWriter.java:140)
at org.apache.spark.shuffle.ShuffleWriteProcessor.write(ShuffleWriteProcessor.scala:59)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:101)
at org.apache.spark.scheduler.Task.run(Task.scala:140)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:565)

Caused by: org.apache.parquet.io.ParquetDecodingException: Can't read value in column [chan_second_cate_cd] optional int32 chan_second_cate_cd at value 292293 out of 478848, 12293 out of 20000 in currentPage. repetition level: 0, definition level: 1
at org.apache.parquet.column.impl.ColumnReaderBase.readValue(ColumnReaderBase.java:553)
at org.apache.parquet.column.impl.ColumnReaderImpl.readValue(ColumnReaderImpl.java:30)
at org.apache.parquet.column.impl.ColumnReaderBase.writeCurrentValueToConverter(ColumnReaderBase.java:439)
at org.apache.parquet.column.impl.ColumnReaderImpl.writeCurrentValueToConverter(ColumnReaderImpl.java:30)
at org.apache.parquet.io.RecordReaderImplementation.read(RecordReaderImplementation.java:406)
at org.apache.parquet.hadoop.InternalParquetRecordReader.nextKeyValue(InternalParquetRecordReader.java:234)

Caused by: java.lang.ArrayIndexOutOfBoundsException: Index 14 out of bounds for length 13
at org.apache.parquet.column.values.dictionary.PlainValuesDictionary$PlainIntegerDictionary.decodeToInt(PlainValuesDictionary.java:251)
at org.apache.parquet.column.values.dictionary.DictionaryValuesReader.readInteger(DictionaryValuesReader.java:108)
at org.apache.parquet.column.impl.ColumnReaderBase$2$3.read(ColumnReaderBase.java:279)
at org.apache.parquet.column.impl.ColumnReaderBase.readValue(ColumnReaderBase.java:533)
```

### Component(s)

_No response_

Guía de contribución

No hay ninguna guía de contribución indexada para este repositorio

Línea de trabajo

Comienza con PlainValuesDictionary.decodeToInt, DictionaryValuesReader.readInteger y la cadena de llamadas de ColumnReaderBase mostrada en el stack trace. Investiga cómo se producen los ID del diccionario al leer páginas codificadas con diccionario, usando como caso de referencia el diccionario informado de 13 entradas y el ID 14. La tarea estará terminada cuando las páginas afectadas puedan leerse sin un acceso al diccionario fuera de límites y el fallo intermitente esté cubierto por una prueba de regresión.

Escrito por el modelo de indexación a partir del texto del issue.

Evaluación

Stack tecnológico
java
Área
data-engineering
Tipo de issue
Error
Dificultad
4/5
Tiempo estimado
3-5 días
Estado de actividad
Tranquilo
Claridad
Necesita aclaración
Aptitud para principiantes
42/100

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.