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)