[FLINK-21469] stop-with-savepoint --drain doesn't advance watermark for sources chained to MultipleInputStreamTask

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.12.1, 1.13.0
• Fix Version/s: 1.14.0, 1.13.1, 1.12.5
• Component/s: API / DataStream, Runtime / Task
• Labels: pull-request-available
• Assignee: Yuan Mei
• Reporter: Piotr Nowojski
• Created: 23/Feb/21 17:53
• Updated: 28/Aug/21 11:21
• Resolved: 12/May/21 12:22

Description

StreamTask#advanceToEndOfEventTime() is used to bump the watermark to MAX_WATERMARK. However this method is only implemented for the source tasks (legacy and FLIP-27). Because of that watermarks are not advanced to end of time if job has sources chained to MultipleInputStreamTask.

Issue Links

• is blocked by: FLINK-21133 FLIP-27 Source does not work with synchronous savepoint
• links to: GitHub Pull Request #15872