[
https://issues.apache.org/jira/browse/BEAM-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sam Whittle updated BEAM-11143:
-------------------------------
Fix Version/s: 2.26.0
> AfterWatermark can leak state for the late trigger when merging windows
> -----------------------------------------------------------------------
>
> Key: BEAM-11143
> URL: https://issues.apache.org/jira/browse/BEAM-11143
> Project: Beam
> Issue Type: Bug
> Components: runner-core
> Reporter: Sam Whittle
> Assignee: Sam Whittle
> Priority: P2
> Fix For: 2.26.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> AfterWatermarkStateMachine attempts to clear the late trigger state when
> merging and the early trigger is not closed in some windows. However it
> appears to clear the state corresponding to the new window, not all of the
> states for the input windows. This leaks the state which can lead to
> unbounded pipeline state buildup.
> https://github.com/apache/beam/blob/68d6c8e6243b1d8f392840273f886276e2a8baff/runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java#L133
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
