beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zhiheng Huang (JIRA)" <>
Subject [jira] [Created] (BEAM-4667) Potential issue with QuantileStateCoder
Date Thu, 28 Jun 2018 02:56:00 GMT
Zhiheng Huang created BEAM-4667:

             Summary: Potential issue with QuantileStateCoder
                 Key: BEAM-4667
             Project: Beam
          Issue Type: Bug
          Components: sdk-java-core
            Reporter: Zhiheng Huang
            Assignee: Kenneth Knowles


The line above encodes the QuantileState buffers.size() as if it's numBuffers. This seems
wrong since before buffers are full, buffers.size() is not equal to numBuffers. One thing
I suspect will happen is that, if we serialize before buffer is full, it will effectively reduce
the number of buffers we maintain after deserialization.

This message was sent by Atlassian JIRA

View raw message