[jira] [Created] (FLINK-21969) PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data

[Shang Yuanchun (Jira)]

Wei Zhong created FLINK-21969:
---------------------------------

             Summary: PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data
                 Key: FLINK-21969
                 URL: https://issues.apache.org/jira/browse/FLINK-21969
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.12.2, 1.13.0
            Reporter: Wei Zhong
            Assignee: Wei Zhong
         Attachments: image-2021-03-25-14-17-06-873.png

Currently the PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data, which makes some registered timer can not be triggered on bounded stream, we need to fix this.

!image-2021-03-25-14-17-06-873.png|width=493,height=284!



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