[
https://issues.apache.org/jira/browse/FLINK-16581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17065254#comment-17065254
]
Jingsong Lee commented on FLINK-16581:
--------------------------------------
Hi [~jark], although
# Look at {{KeyedProcessFunctionWithCleanupState}} , we already have many
operators that use processing-time timer to cleanup state.
# Now default timer is rocksDb? In FLINK-15637
I prefer using StateTtlConfig too, It should be unified to DataStream. But why
we not use it in 1.9? Can you explain more about "can't cleanup multiple states
at the same time."?
> 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)
