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)
