[ https://issues.apache.org/jira/browse/FLINK-6656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16019721#comment-16019721 ]
ASF GitHub Bot commented on FLINK-6656: --------------------------------------- Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/3961 Just a question from my side to understand this change better. Does it really leverage the fact of keys being returned in order? To evaluate `getSortedTimestamps` you need to iterate whole keySet anyway. I see though it benefits from laziness of value deserialization and partitioning of the incoming events (by timestamp). Is my understanding correct? > Migrate CEP PriorityQueue to MapState > ------------------------------------- > > Key: FLINK-6656 > URL: https://issues.apache.org/jira/browse/FLINK-6656 > Project: Flink > Issue Type: Bug > Components: CEP > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > Fix For: 1.3.0 > > -- This message was sent by Atlassian JIRA (v6.3.15#6346)