Details
-
Bug
-
Status: Resolved
-
P1
-
Resolution: Fixed
-
2.23.0, 2.24.0
-
None
Description
Pipeline might stop progressing watermark in certain cases due to timer output timestamp not being released from FlinkTimerInternals#outputTimestampQueue. The pipeline has to be restarted from checkpoint to reload the cache and free watermark hold.
Attachments
Issue Links
- is related to
-
BEAM-10676 Timers use the input timestamp as the timer output timestamp which prevents watermark progress
- Resolved
- links to