[
https://issues.apache.org/jira/browse/FLINK-5174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas closed FLINK-5174.
---------------------------------
Resolution: Duplicate
> 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
>
> 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.15#6346)
