Kostas Kloudas created FLINK-5174:
-------------------------------------
Summary: Fix memory leak in the CEP library.
Key: FLINK-5174
URL: https://issues.apache.org/jira/browse/FLINK-5174
Project: Flink
Issue Type: Bug
Components: CEP
Affects Versions: 1.1.3
Reporter: Kostas Kloudas
Assignee: Kostas Kloudas
Fix For: 1.2.0
Currently the CEP library stores all the keys it has seen so far, so that when
the time comes, it can iterate over all the stored NFAs and update them
accordingly.
This implies that the state is never cleaned up and it can lead to memory
issues.
To improve this, we could register timers for each new element and for the
specific key, so that 1) only the relevant NFAs are fetched, and 2) the timers
will be gc'ed upon firing.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
