[FLINK-20169] Move emitting MAX_WATERMARK out of SourceOperator processing loop

• Type: Improvement
• Status: Closed
• Priority: Blocker
• Resolution: Implemented
• Fix Version/s: 1.12.0, 1.11.3
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 16/Nov/20 09:18
• Updated: 12/Dec/20 11:59
• Resolved: 16/Nov/20 16:24

Description

It would be better to move checking for END_OF_INPUT and emitting the MAX_WATERMARK out of the SourceOperator#processInput.

Issue Links

• links to: GitHub Pull Request #14078