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] [Created] (BEAM-14244) Processing time timers should use outputTimestamp rather than input watermark for their timestamp

Steve Niemitz created BEAM-14244:
------------------------------------

             Summary: 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


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)