flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "yuemeng (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-9201) same merge window will be fired twice if watermark already pass the new merged window
Date Wed, 18 Apr 2018 09:33:00 GMT

     [ 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),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.

 

 


> 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)

Mime
View raw message