[jira] [Created] (FLINK-5174) Fix memory leak in the CEP library.

[Shang Yuanchun (Jira)]

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)