You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "aitozi (JIRA)" <ji...@apache.org> on 2018/06/22 07:57:00 UTC

[jira] [Created] (FLINK-9642) Reduce the count to deal with state during a CEP process

aitozi created FLINK-9642:
-----------------------------

             Summary: Reduce the count to deal with state during a CEP process 
                 Key: FLINK-9642
                 URL: https://issues.apache.org/jira/browse/FLINK-9642
             Project: Flink
          Issue Type: Improvement
          Components: CEP
    Affects Versions: 1.6.0
            Reporter: aitozi
            Assignee: aitozi


With the rework of sharedBuffer Flink-9418, the lock & release operation is deal with rocksdb state which is different from the previous version which will read the state of sharedBuffer all to memory, i think we can add a cache or variable in sharedbuffer to cache the LockAble Object to mark the ref change in once process in NFA, this will reduce the count when the events point to the same NodeId.. And flush the result to MapState at the end of process. 



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