[FLINK-27676][python] Fix on_timer output behind triggering watermark
authorJuntao Hu <maybachhjt@gmail.com>
Wed, 18 May 2022 09:14:49 +0000 (17:14 +0800)
committerhuangxingbo <hxbks2ks@gmail.com>
Thu, 19 May 2022 12:08:21 +0000 (20:08 +0800)
commit124e4adb04196e5d56974aead02e61a9bd5bf2cf
treef6f9770f315ceff0864437689c76e944315d97d6
parentcc63db735e32d6b15ad77e9245accfe21f45581b
[FLINK-27676][python] Fix on_timer output behind triggering watermark

This closes #19765.
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOperator.java
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/PythonKeyedCoProcessOperator.java
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/PythonKeyedProcessOperator.java
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/timer/TimerRegistration.java
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/timer/TimerUtils.java