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/06 13:54:00 UTC

[jira] [Created] (BEAM-14265) Flink should hold the watermark at the output timestamp for processing time timers

Steve Niemitz created BEAM-14265:
------------------------------------

             Summary: Flink should hold the watermark at the output timestamp for processing time timers
                 Key: BEAM-14265
                 URL: https://issues.apache.org/jira/browse/BEAM-14265
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Steve Niemitz


Currently the Flink runner doesn't support output timestamps on processing time timers, and instead uses the current output watermark when the timer fires.

We should update the runner to correctly set a watermark hold at the output timestamp and use it when firing the timer.



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