[BEAM-12931] Timer.setOutputTimestamp doesn't take into account for DoFn#getAllowedTimestampSkew()

• Type: Bug
• Status: Triage Needed
• Priority: P2
• Resolution: Fixed
• Fix Version/s: Missing
• Component/s: beam-model
• Assignee: Lara Schmidt
• Reporter: Lara Schmidt
• Created: 21/Sep/21 22:19
• Updated: 13/Apr/23 11:08
• Resolved: 12/Jan/22 17:37

Description

A DoFn may emit elements with a timestamp up to DoFn#getAllowedTimestampSkew() before the current element's timestamp. However getAllowedTimestampSkew is not properly accounted for in looking at the output timestamp of a timer.

Context: https://lists.apache.org/thread.html/r7554658114ddde86c5d82e1c39fe7e1ef587fe926b8e406d1130d501%40%3Cdev.beam.apache.org%3E

Issue Links

• links to: GitHub Pull Request #15540