hehuiyuan created FLINK-26565:
---------------------------------

             Summary: Use lateTrigger when the window maxtimestap of data is 
less than currentwatermark and  it is not discarded because the allow latency 
parameter 
                 Key: FLINK-26565
                 URL: https://issues.apache.org/jira/browse/FLINK-26565
             Project: Flink
          Issue Type: Improvement
            Reporter: hehuiyuan
         Attachments: image-2022-03-10-11-27-52-891.png

Use lateTrigger when the window maxtimestap of data is less than 
currentwatermark and  it is not discarded because the allow latency parameter.

!image-2022-03-10-11-27-52-891.png|width=543,height=318!



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to