Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
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.
Attachments
Issue Links
- causes
-
BEAM-10054 Direct Runner execution stalls with test pipeline
- Resolved
- links to