Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-5222

Parquet IO position invalid when writing integers

Details

    • Bug
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • io-java-parquet
    • None

    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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            ghilios George Hilios
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: