[hotfix][python] Fix the wrong clearing state logic on processing tim…

…e window
liuyongvs · Jan 3, 2023 · eb01783 · eb01783
1 parent 187e572
commit eb01783
Showing 1 changed file with 1 addition and 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
@@ -497,7 +497,7 @@ def on_processing_time(self, timestamp, key, namespace):
         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)