Details
-
Bug
-
Status: Open
-
P1
-
Resolution: Unresolved
-
2.39.0
-
None
Description
Currently the Flink runner doesn't support output timestamps on processing time timers, and instead uses the current output watermark when the timer fires.
We should update the runner to correctly set a watermark hold at the output timestamp and use it when firing the timer.
Attachments
Issue Links
- links to