[jira] [Created] (FLINK-9201) same merge window will fire twice if watermark already pass the window for merge windows

[Shang Yuanchun (Jira)]

yuemeng created FLINK-9201:
------------------------------

             Summary: same merge window will fire twice if watermark already pass the window for merge windows
                 Key: FLINK-9201
                 URL: https://issues.apache.org/jira/browse/FLINK-9201
             Project: Flink
          Issue Type: Bug
          Components: Core
    Affects Versions: 1.3.3
            Reporter: yuemeng
            Assignee: yuemeng


sum with session window,.

suppose the session gap is 3 seconds and allowedlateness is 60 seconds

w1,TimeWindow[1,9] had elements,1,2,3,6,will be fired if watermark reached 9

 if a late element (w2,TimeWindow[7,10]) had come but the watermark already at 11.

w1,w2 will be merged a new window w3 TimeWindow[1,10] and will be register a new timer by call triggerContext.onMerge(mergedWindows),then w3 will be fired later by call triggerContext.onElement(element) because of the watermark pass the w3.

but w3 will be fired again because of the timer < current watermark.

that mean w3 will be fired  twice because of watermark pass the new merge window w3.

 

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)