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

Posted to commits@beam.apache.org by "Thomas Groh (JIRA)" <ji...@apache.org> on 2017/03/23 15:54:41 UTC

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

     [ https://issues.apache.org/jira/browse/BEAM-576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Thomas Groh updated BEAM-576:
-----------------------------
    Description: 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.  (was: 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.)

> 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: Minor
>
> 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
(v6.3.15#6346)