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)

Reply via email to