[FLINK-26775] PyFlink WindowOperator#process_element register wrong cleanup timer

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.15.0
• Fix Version/s: 1.14.5, 1.15.0, 1.13.7
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Juntao Hu
• Reporter: Juntao Hu
• Created: 21/Mar/22 11:18
• Updated: 22/Mar/22 07:19
• Resolved: 22/Mar/22 07:19

Description

In window_operator.py line 378, when dealing with merging window assigner:

self.register_cleanup_timer(window)

This should be registering a cleanup timer for `actual_window`, but won't causing window emitting bugs when session window trigger is implemented correctly.

Issue Links

• links to: GitHub Pull Request #19186