[ https://issues.apache.org/jira/browse/BEAM-576 ]


    Danny McCormick deleted comment on BEAM-576:
    --------------------------------------

was (Author: JIRAUSER282469):
This issue has been migrated to [https://github.com/apache/beam/issues/17902]

> ReduceFnRunner should GC based on current WM, not on a fired Timer
> ------------------------------------------------------------------
>
>                 Key: BEAM-576
>                 URL: https://issues.apache.org/jira/browse/BEAM-576
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-java-core
>            Reporter: Thomas Groh
>            Priority: P3
>              Labels: Clarified
>
> ReduceFnRunner currently uses the time of a timer to determine if it is the 
> garbage collection timer. Instead, it should examine the time a window is 
> expired and the current input watermark to determine if the window should be 
> Garbage Collected. It should additionally ignore all timers for windows that 
> have already been expired.



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

Reply via email to