lsyldliu commented on pull request #11830: URL: https://github.com/apache/flink/pull/11830#issuecomment-693496800
> Hi @lsyldliu , I just find that the current implementation doesn't cover the state cleanup for DataViews (i.g. ListView, MapView). This will result in the state size increases unlimited when `count distinct` or `listagg` is used. We should pass the `StateTtlConfig` to the creation of StateDataView (e.g. `PerKeyStateDataViewStore`). Hi, @wuchong , I have pass the `StateTtlConfig` to `PerKeyStateDataViewStore ` as constructing parameter, when create `StateDataView` we will judge `StateTtlConfig` whether enable state TTL, so we can clean the StateDataView state timely for `count distinct` or `listagg`. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
