Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21969

PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data

Details

    Description

      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.

      Attachments

        Issue Links

          Activity

            zhongwei Wei Zhong added a comment -

            Merged into master via 5b3a8f3b25dcac71375d1a81fa63d935c8bf3eab

            Merged into release-1.12 via 70d514360ce34dc47e4e95311baf1eb816380c98

            zhongwei Wei Zhong added a comment - Merged into master via 5b3a8f3b25dcac71375d1a81fa63d935c8bf3eab Merged into release-1.12 via 70d514360ce34dc47e4e95311baf1eb816380c98

            People

              zhongwei Wei Zhong
              zhongwei Wei Zhong
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: