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)
