You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Juntao Hu (Jira)" <ji...@apache.org> on 2022/05/22 15:14:00 UTC

[jira] [Created] (FLINK-27733) Rework on_timer output behind watermark bug fix

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)