[
https://issues.apache.org/jira/browse/FLINK-31949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen reassigned FLINK-31949:
----------------------------------
Assignee: Shuyi Chen
> The state of CountTumblingWindowAssigner of Python DataStream API were never
> purged
> -----------------------------------------------------------------------------------
>
> Key: FLINK-31949
> URL: https://issues.apache.org/jira/browse/FLINK-31949
> Project: Flink
> Issue Type: Bug
> Components: API / Python
> Reporter: Dian Fu
> Assignee: Shuyi Chen
> Priority: Major
>
> Posted By Urs from user-mailing list:
> {code:java}
> "In FLINK-26444, a couple of convenience window assigners were added to
> the Python Datastream API, including CountTumblingWindowAssigner. This
> assigner uses a CountTrigger by default, which produces TriggerResult.FIRE.
> As such, using this window assigner on a data stream will always produce
> a "state leak" since older count windows will always be retained without
> any chance to work on the elements again."
> {code}
> See [https://lists.apache.org/thread/ql8x283xzgd98z0vsqr9npl5j74hscsm] for
> more details.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
