[flink] branch release-1.15 updated: [hotfix][python] Fix the wrong clearing state logic on processing time window

[hxb]

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

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


The following commit(s) were added to refs/heads/release-1.15 by this push:
     new b61ba023855 [hotfix][python] Fix the wrong clearing state logic on 
processing time window
b61ba023855 is described below

commit b61ba02385552f967d863dd1b2cbfce1552de1ca
Author: huangxingbo <h...@apache.org>
AuthorDate: Tue Jan 3 15:39:12 2023 +0800

    [hotfix][python] Fix the wrong clearing state logic on processing time 
window
---
 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 234bc97863b..a165a34a02c 100644
--- a/flink-python/pyflink/fn_execution/datastream/window/window_operator.py
+++ b/flink-python/pyflink/fn_execution/datastream/window/window_operator.py
@@ -483,7 +483,7 @@ class WindowOperator(object):
         if trigger_result.is_purge():
             self.window_state.clear()
 
-        if self.window_assigner.is_event_time() and self.is_cleanup_time(
+        if not self.window_assigner.is_event_time() and self.is_cleanup_time(
                 self.trigger_context.window, timestamp):
             self.clear_all_state(self.trigger_context.window, 
self.window_state, merging_windows)