Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.12.2, 1.13.0
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
Attachments
Issue Links
- fixes
-
FLINK-21559 Python DataStreamTests::test_process_function failed on AZP
- Closed
- links to
Merged into master via 5b3a8f3b25dcac71375d1a81fa63d935c8bf3eab
Merged into release-1.12 via 70d514360ce34dc47e4e95311baf1eb816380c98