Sam Rohde created BEAM-8581:
-------------------------------
Summary: Python SDK labels ontime empty panes as late
Key: BEAM-8581
URL: https://issues.apache.org/jira/browse/BEAM-8581
Project: Beam
Issue Type: Bug
Components: sdk-py-core
Reporter: Sam Rohde
Assignee: Sam Rohde
The GeneralTriggerDriver does not put watermark holds on timers, leading to the
ontime empty pane being considered late data.
Fix: Add a new notion of whether a trigger has an ontime pane. If it does, then
set a watermark hold to end of window - 1.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
