[flink] branch release-1.14 updated: [FLINK-26775][python] WindowOperator#process_element registers wrong cleanup timer

[di...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.14 by this push:
     new a0dd7aa  [FLINK-26775][python] WindowOperator#process_element registers wrong cleanup timer
a0dd7aa is described below

commit a0dd7aac8128a6a84fb712c820c1233c66c7a6c1
Author: Juntao Hu <ma...@gmail.com>
AuthorDate: Mon Mar 21 19:48:32 2022 +0800

    [FLINK-26775][python] WindowOperator#process_element registers wrong cleanup timer
    
    This closes #19186.
---
 flink-python/pyflink/fn_execution/datastream/window/window_operator.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-python/pyflink/fn_execution/datastream/window/window_operator.py b/flink-python/pyflink/fn_execution/datastream/window/window_operator.py
index 724c527..276afdf 100644
--- a/flink-python/pyflink/fn_execution/datastream/window/window_operator.py
+++ b/flink-python/pyflink/fn_execution/datastream/window/window_operator.py
@@ -376,7 +376,7 @@ class WindowOperator(object):
 
                 if trigger_result.is_purge():
                     self.window_state.clear()
-                self.register_cleanup_timer(window)
+                self.register_cleanup_timer(actual_window)
 
             merging_windows.persist()
         else: