Zakelly Lan created FLINK-36892:
-----------------------------------

             Summary: Properly handle the watermark status
                 Key: FLINK-36892
                 URL: https://issues.apache.org/jira/browse/FLINK-36892
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Task
            Reporter: Zakelly Lan
            Assignee: Zakelly Lan


The watermark status is not properly handle in async state processing. It is 
emitted to downstream synchronously, while the watermarks will respect the 
ongoing timer processing. That should be fixed and aligned.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to