This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 14d32f6 [FLINK-26775][python] WindowOperator#process_element
registers wrong cleanup timer
14d32f6 is described below
commit 14d32f628e004f5012189de0626302fe6cb32f18
Author: Juntao Hu <[email protected]>
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 0e4575f..234bc97 100644
--- a/flink-python/pyflink/fn_execution/datastream/window/window_operator.py
+++ b/flink-python/pyflink/fn_execution/datastream/window/window_operator.py
@@ -375,7 +375,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: