You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Danny McCormick (Jira)" <ji...@apache.org> on 2022/06/03 16:20:00 UTC

[jira] (BEAM-576) ReduceFnRunner should GC based on current WM, not on a fired Timer

    [ 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)