You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by "Thomas Groh (JIRA)" <ji...@apache.org> on 2016/06/01 23:31:59 UTC

[jira] [Created] (BEAM-323) The InProcessPipelineRunner uses user objects for State and Timer lookups

Thomas Groh created BEAM-323:
--------------------------------

             Summary: The InProcessPipelineRunner uses user objects for State and Timer lookups
                 Key: BEAM-323
                 URL: https://issues.apache.org/jira/browse/BEAM-323
             Project: Beam
          Issue Type: Bug
          Components: runner-direct
            Reporter: Thomas Groh
            Assignee: Thomas Groh
            Priority: Critical


The runner keys state based on the user key that it was grouped by, instead of the structural value of that key. This causes callbacks to be updated based on java equality, so an object with a poor equals can cause the Pipeline to not progress.

Initially uncovered in https://github.com/apache/incubator-beam/pull/409



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)