Juntao Hu created FLINK-27733: --------------------------------- Summary: Rework on_timer output behind watermark bug fix Key: FLINK-27733 URL: https://issues.apache.org/jira/browse/FLINK-27733 Project: Flink Issue Type: Improvement Components: API / Python Affects Versions: 1.15.0 Reporter: Juntao Hu Fix For: 1.16.0
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. -- This message was sent by Atlassian Jira (v8.20.7#820007)