Piotr Nowojski created FLINK-23698:
--------------------------------------
Summary: Pass watermarks in finished on restore operators
Key: FLINK-23698
URL: https://issues.apache.org/jira/browse/FLINK-23698
Project: Flink
Issue Type: Sub-task
Components: Runtime / Task
Affects Versions: 1.14.0
Reporter: Piotr Nowojski
Assignee: Piotr Nowojski
Fix For: 1.14.0
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
