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)
