Details
-
Sub-task
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
1.14.0
-
None
Description
After merging FLINK-23541 there is a bug on restore finished tasks that we are loosing an information that max watermark has been already emitted. As task is finished, it means no new watermark will be ever emitted, while downstream tasks (for example two/multiple input tasks) would be deadlocked waiting for a watermark from an already finished input.
Attachments
Issue Links
- relates to
-
FLINK-23708 When task is finishedOnRestore Operators shouldn't be used
- Closed