[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuemeng updated FLINK-9201:
---------------------------
Description:
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),w3 will be fired first
time by call triggerContext.onElement(element) because of the watermark pass
the w3.
w3 will be fired second times because of the timer < current watermark.
that mean w3 will be fired twice because of watermark pass the new merge
window w3.
was:
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.
> same merge window will be fired twice if watermark already pass the new
> merged window
> -------------------------------------------------------------------------------------
>
> 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
> Priority: Blocker
>
> 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),w3 will be fired
> first time by call triggerContext.onElement(element) because of the watermark
> pass the w3.
> w3 will be fired second times 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)
