You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2023/04/27 03:21:00 UTC

[jira] [Created] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged

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)