[jira] [Created] (FLINK-14239) Emitting the max watermark in StreamSource#run may cause it to arrive the downstream early

[Shang Yuanchun (Jira)]

Haibo Sun created FLINK-14239:
---------------------------------

             Summary: Emitting the max watermark in StreamSource#run may cause it to arrive the downstream early
                 Key: FLINK-14239
                 URL: https://issues.apache.org/jira/browse/FLINK-14239
             Project: Flink
          Issue Type: Bug
            Reporter: Haibo Sun
             Fix For: 1.10.0


For {{Source}}, the max watermark is emitted in {{StreamSource#run}} currently. If some records are also output in {{close}} of {{RichSourceFunction}}, then the max watermark will reach the downstream operator before these records.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)