Juntao Hu created FLINK-26775: --------------------------------- Summary: PyFlink WindowOperator#process_element register wrong cleanup timer Key: FLINK-26775 URL: https://issues.apache.org/jira/browse/FLINK-26775 Project: Flink Issue Type: Bug Components: API / Python Affects Versions: 1.15.0 Reporter: Juntao Hu Fix For: 1.15.0
In window_operator.py line 378, when dealing with merging window assigner: {code:python} self.register_cleanup_timer(window) {code} This should be registering a cleanup timer for `actual_window`, but won't causing window emitting bugs when session window trigger is implemented correctly. -- This message was sent by Atlassian Jira (v8.20.1#820001)