[jira] [Created] (FLINK-2181) SessionWindowing example has a memleak

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-2181) SessionWindowing example has a memleak

Shang Yuanchun (Jira)
Gabor Gevay created FLINK-2181:
----------------------------------

             Summary: SessionWindowing example has a memleak
                 Key: FLINK-2181
                 URL: https://issues.apache.org/jira/browse/FLINK-2181
             Project: Flink
          Issue Type: Bug
          Components: Examples, Streaming
            Reporter: Gabor Gevay
            Assignee: Gabor Gevay


The trigger policy objects belonging to already terminated sessions are kept in memory, and also NotifyOnLastGlobalElement gets called on them. This causes the program to eat up more and more memory, and also to get slower with time.

Mailing list discussion:
http://mail-archives.apache.org/mod_mbox/flink-dev/201505.mbox/%3CCADXjeyBW9uaA=ayDe+9r+qH85PBLyAvUeGSr7h8PwkYntM99Dg@...%3E



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)