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

dalongliu updated FLINK-19207:
------------------------------
    Description: In Flink-17096 , we are using TTL State refactor group Agg 
function state expiration implement instead of Timer way. However, there’s a 
slight problem which AggregateITCase#testListAggWithRetraction test failed 
because of *IteratorWithCleanup* didn't support remove element, so maybe we 
need to support {{remove}} for {{TtlListState#IteratorWithCleanup.}}  (was: In 
[Flink-17096|https://issues.apache.org/jira/browse/FLINK-17096] , we are using 
TTL State refactor group Agg function state expiration implement instead of 
Timer way. However, there’s a slight problem which 
AggregateITCase#testListAggWithRetraction test failed because of 
IteratorWithCleanup didn't support remove element, so maybe we need to support 
{{remove}} for {{TtlListState#IteratorWithCleanup.}})

> TtlListState#IteratorWithCleanup support remove method
> ------------------------------------------------------
>
>                 Key: FLINK-19207
>                 URL: https://issues.apache.org/jira/browse/FLINK-19207
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / State Backends
>    Affects Versions: 1.12.0
>            Reporter: dalongliu
>            Priority: Critical
>
> In Flink-17096 , we are using TTL State refactor group Agg function state 
> expiration implement instead of Timer way. However, there’s a slight problem 
> which AggregateITCase#testListAggWithRetraction test failed because of 
> *IteratorWithCleanup* didn't support remove element, so maybe we need to 
> support {{remove}} for {{TtlListState#IteratorWithCleanup.}}



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

Reply via email to