[
https://issues.apache.org/jira/browse/FLINK-17942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117517#comment-17117517
]
Benchao Li commented on FLINK-17942:
------------------------------------
[~jark] Yes. I'd like to fix this. Actually, we need to fix for the regular
aggregate count distinct too, do you think we need to open another issue or fix
it in this issue?
> Count distinct could not clean state in WindowOperator
> ------------------------------------------------------
>
> Key: FLINK-17942
> URL: https://issues.apache.org/jira/browse/FLINK-17942
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.9.3, 1.10.1, 1.11.0
> Reporter: Benchao Li
> Priority: Major
> Fix For: 1.11.0
>
>
> MapView.clear() is generated in NamespaceAggsHandleFunction.cleanup, however
> it's never been called in WindowOperator in blink planner.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
