Eugene Kirpichov created BEAM-4557: -------------------------------------- Summary: Propagate keyed-ness of PValues properly in ReferenceRunner Key: BEAM-4557 URL: https://issues.apache.org/jira/browse/BEAM-4557 Project: Beam Issue Type: Bug Components: runner-direct Reporter: Eugene Kirpichov Assignee: Kenneth Knowles
ULR, just like regular direct runner, needs to respect "keyed"-ness of certain PValues, for two purposes: 1) invoking transforms of those PValues serially per key (e.g. because some of such transform evaluators, such as GABW, are not thread-safe per key), and 2) supporting state and timers. In [https://github.com/apache/beam/pull/5585,] one of the commits adds such tracking, but only naively - directly on the outputs of GBKO and GABW, without propagating downstream through key-preserving DoFn's. This Jira is to mimic the behavior of KeyedPValueTrackingVisitor in ULR. -- This message was sent by Atlassian JIRA (v7.6.3#76005)