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

Posted to issues@beam.apache.org by "Steve Niemitz (Jira)" <ji...@apache.org> on 2022/04/04 16:12:00 UTC

[jira] [Assigned] (BEAM-14244) Processing time timers should use outputTimestamp rather than input watermark for their timestamp

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

Steve Niemitz reassigned BEAM-14244:
------------------------------------

    Assignee: Steve Niemitz

> Processing time timers should use outputTimestamp rather than input watermark for their timestamp
> -------------------------------------------------------------------------------------------------
>
>                 Key: BEAM-14244
>                 URL: https://issues.apache.org/jira/browse/BEAM-14244
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-core, sdk-java-core
>            Reporter: Steve Niemitz
>            Assignee: Steve Niemitz
>            Priority: P1
>
> Currently processing time timers ignore the outputTimestamp and instead use the input watermark at the time they fire.  This is wrong because the input watermark can have advanced arbitrarily far past the actual output timestamp when it fires.
> The correct behavior should be to instead use the outputTimestamp the timer was configured to fire with.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)