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)
