[jira] [Created] (FLINK-9620) Add an alternative option to choose when deal with eventtime cep

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-9620) Add an alternative option to choose when deal with eventtime cep

Shang Yuanchun (Jira)
aitozi created FLINK-9620:
-----------------------------

             Summary: Add an alternative option to choose when deal with eventtime cep
                 Key: FLINK-9620
                 URL: https://issues.apache.org/jira/browse/FLINK-9620
             Project: Flink
          Issue Type: Improvement
            Reporter: aitozi
            Assignee: aitozi


Now when deal with eventtime, it use the elementQueue to buffer event to work with the out of order data, I think its ok. But when the key is very  fragmented, every time the watermark advanced , all key's timer have to been evaluted. What about add an alternative option that indicates the stream has been ordered updtream, which will simply the logic when deal with cep eventtime, the work of ordering a stream by time can be done upstream by userself by the window or other way. 

What's your guys idea [~dawidwys] [~kkl0u]



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