You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@beam.apache.org by "Sam Whittle (Jira)" <ji...@apache.org> on 2020/10/27 20:17:00 UTC
[jira] [Created] (BEAM-11144) TriggerStateMachine.prefetchOnElement
and other prefetch methods use incorrect state for subtriggers
Sam Whittle created BEAM-11144:
----------------------------------
Summary: TriggerStateMachine.prefetchOnElement and other prefetch methods use incorrect state for subtriggers
Key: BEAM-11144
URL: https://issues.apache.org/jira/browse/BEAM-11144
Project: Beam
Issue Type: Bug
Components: runner-core
Reporter: Sam Whittle
Assignee: Sam Whittle
prefetchOnElement takes a single StateAccessor corresponding to the root trigger. It uses that state accessor to perform prefetches for the subtrigger state. However that will use the root trigger namespace for the tags in the subtriggers. This makes prefetching ineffective, introducing possibly an additional round-trip once the data is actually read.
https://github.com/apache/beam/blob/68d6c8e6243b1d8f392840273f886276e2a8baff/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java#L296
--
This message was sent by Atlassian Jira
(v8.3.4#803005)