Dawid Wysakowicz created FLINK-20169: ----------------------------------------
Summary: Move emitting MAX_WATERMARK out of SourceOperator processing loop Key: FLINK-20169 URL: https://issues.apache.org/jira/browse/FLINK-20169 Project: Flink Issue Type: Improvement Components: Runtime / Task Reporter: Dawid Wysakowicz Assignee: Dawid Wysakowicz Fix For: 1.12.0 It would be better to move checking for END_OF_INPUT and emitting the MAX_WATERMARK out of the SourceOperator#processInput. -- This message was sent by Atlassian Jira (v8.3.4#803005)