[BEAM-5222] Parquet IO position invalid when writing integers

• Type: Bug
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: io-java-parquet
• Assignee: Unassigned
• Reporter: George Hilios
• Created: 27/Aug/18 12:05
• Updated: 03/Jun/22 21:54

Description

Please see https://github.com/apache/beam/blob/master/sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java#L345

On write(int b), position is incremented by 1. On write(byte[] b, int off, int len) position is incremented by the length of the byte array.

write(int b) should increment by 4 bytes, if I'm understanding correctly.