[ https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17066429#comment-17066429 ]
dalongliu commented on FLINK-16581: ----------------------------------- [~jark] I agree with you, use StateTtlConfig can simplify the implementation a lot, thanks for your guidance, I will modify the code. > can't cleanup multiple states at the same time For this problem, I think user should discard the expired data in SQL, otherwise, the result will be affected! > Minibatch deduplication lack state TTL > -------------------------------------- > > Key: FLINK-16581 > URL: https://issues.apache.org/jira/browse/FLINK-16581 > Project: Flink > Issue Type: Bug > Components: Table SQL / Runtime > Affects Versions: 1.9.2, 1.10.0 > Reporter: Jingsong Lee > Assignee: dalongliu > Priority: Critical > Fix For: 1.9.3, 1.10.1, 1.11.0 > > > This lead to OOM with long running streaming job. > We should check all unbounded operations, should not lack state TTL -- This message was sent by Atlassian Jira (v8.3.4#803005)