Dian Fu created FLINK-31949:
-------------------------------
Summary: 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
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)
