[ https://issues.apache.org/jira/browse/FLINK-5420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kostas Kloudas updated FLINK-5420: ---------------------------------- Summary: Make CEP operators rescalable (was: Make keyed CEP operator rescalable) > Make CEP operators rescalable > ----------------------------- > > Key: FLINK-5420 > URL: https://issues.apache.org/jira/browse/FLINK-5420 > Project: Flink > Issue Type: Bug > Components: CEP > Affects Versions: 1.2.0 > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > > {{AbstractKeyedCEPPatternOperator}} uses the old state snapshotting > interfaces that make the operator non-resealable. The operator uses state to > keep track of all the in-flight keys. When a watermark arrives the buffers > are checked for all keys and those that can be processed are processed. We > could change this to use the abstract timer system instead. -- This message was sent by Atlassian JIRA (v6.3.15#6346)