flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "zhaoshijie (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-11139) stream non window join support state ttl
Date Wed, 12 Dec 2018 08:02:00 GMT
zhaoshijie created FLINK-11139:

             Summary: stream non window join support state ttl
                 Key: FLINK-11139
                 URL: https://issues.apache.org/jira/browse/FLINK-11139
             Project: Flink
          Issue Type: Improvement
          Components: Table API &amp; SQL
    Affects Versions: 1.7.0
            Reporter: zhaoshijie

stream non window join function use timer to delete expired data,it is ok for small amount
of data or short expiration time,but it will be OOM(too many timer)on taskManger  when
there  is a long expiration time and  a large amount of data。In fact, table module other
state function has same problem,I would like to contribute to fix it。

This message was sent by Atlassian JIRA

View raw message