[ 
https://issues.apache.org/jira/browse/FLINK-17096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

dalongliu updated FLINK-17096:
------------------------------
    Description: At the moment, MiniBatch Group Agg include Local/Global 
doesn`t support State TTL, for streaming job, it will lead to OOM in long time 
running, so we need to make state data expire after ttl, the solution is that 
use incremental cleanup feature refer to FLINK-16581  (was: At the moment, 
MiniBatch Group Agg include Local/Global doesn`t support State TTL, for 
streaming job, it will lead to OOM in long time running, so we need to make 
state data expire after ttl, the solution is that use incremental cleanup 
feature refer to [link 
FLINK-16581|https://issues.apache.org/jira/browse/FLINK-16581])

> Minibatch Group Agg support state ttl
> -------------------------------------
>
>                 Key: FLINK-17096
>                 URL: https://issues.apache.org/jira/browse/FLINK-17096
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table SQL / Runtime
>    Affects Versions: 1.9.0, 1.10.0
>            Reporter: dalongliu
>            Assignee: dalongliu
>            Priority: Critical
>             Fix For: 1.11.0
>
>
> At the moment, MiniBatch Group Agg include Local/Global doesn`t support State 
> TTL, for streaming job, it will lead to OOM in long time running, so we need 
> to make state data expire after ttl, the solution is that use incremental 
> cleanup feature refer to FLINK-16581



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to