[ 
https://issues.apache.org/jira/browse/FLINK-7384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321639#comment-17321639
 ] 

Flink Jira Bot commented on FLINK-7384:
---------------------------------------

This issue and all of its Sub-Tasks have not been updated for 180 days. So, it 
has been labeled "stale-minor". If you are still affected by this bug or are 
still interested in this issue, please give an update and remove the label. In 
7 days the issue will be closed automatically.

> Unify event and processing time handling in the 
> AbstractKeyedCEPPatternOperator.
> --------------------------------------------------------------------------------
>
>                 Key: FLINK-7384
>                 URL: https://issues.apache.org/jira/browse/FLINK-7384
>             Project: Flink
>          Issue Type: Improvement
>          Components: Library / CEP
>            Reporter: Kostas Kloudas
>            Priority: Minor
>              Labels: pull-request-available, stale-minor
>          Time Spent: 10m
>  Remaining Estimate: 0h
>
> With the recent changes introduced in 
> https://issues.apache.org/jira/browse/FLINK-7293, the code paths between 
> event- and processing-time handling are very close. This gives an opportunity 
> to unify the 2 paths.
> To do this when operating in processing time, the user will specify an 
> interval (like the watermark interval in event time), during which elements 
> will be buffered, and only when this interval expires, the elements will be 
> emitted. This is the same as the case of event-time, where elements between 
> watermarks are buffered.
> This change will remove the need to register a processing time timer for 
> every millisecond and it will also allow to emit timed-out patterns in 
> processing time without having to wait for the "next" element to arrive.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to