-
Type:
Bug
-
Status: Resolved
-
Priority:
P2
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: 2.19.0
-
Component/s: sdk-py-core
-
Labels:None
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.
- causes
-
BEAM-10054 Direct Runner execution stalls with test pipeline
-
- Resolved
-
- links to