Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6205#discussion_r197627451
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/SharedBuffer.java
---
@@ -75,6 +76,9 @@
private MapState<Long, Integer> eventsCount;
private MapState<NodeId, Lockable<SharedBufferNode>> entries;
+ private HashMap<EventId, Lockable<V>> eventsBufferCache = new
HashMap<>();
+ private HashMap<NodeId, Lockable<SharedBufferNode>> entryCache = new
HashMap<>();
--- End diff --
I would suggest change it to
`private Map<EventId, Lockable<V>> eventsBufferCache = new HashMap<>();`
---
