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

XML

Word

Printable

JSON

Details

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

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.

Attachments

Issue Links

is blocked by

FLINK-21133 FLIP-27 Source does not work with synchronous savepoint

Resolved

links to

GitHub Pull Request #15872

Activity

People

Assignee:: Yuan Mei

Reporter:: Piotr Nowojski

Votes:: 0 Vote for this issue

Watchers:: 7 Start watching this issue

Dates

Created:: 23/Feb/21 17:53

Updated:: 28/Aug/21 11:21

Resolved:: 12/May/21 12:22