[FLINK-27733] Rework on_timer output behind watermark bug fix

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.14.4, 1.15.0
• Fix Version/s: 1.14.5, 1.15.1, 1.16.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Juntao Hu
• Reporter: Juntao Hu
• Created: 22/May/22 15:13
• Updated: 24/May/22 02:28
• Resolved: 24/May/22 02:28

Description

FLINK-27676 can be simplified by just checking isBundleFinished() before emitting watermark in AbstractPythonFunctionOperator, and this fix FLINK-27676 in python group window aggregate too.

Issue Links

• links to: GitHub Pull Request #19788