Hi Urs, I guess you are right. This seems like a bug which should be addressed.
Regards, Dian On Mon, Apr 24, 2023 at 5:07 AM Urs Schönenberger < urs.schoenenber...@tngtech.com> wrote: > Hi all, > > 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. > > Unless I am mistaken, the only way to use this assigner would be to > override its trigger with .trigger() afterwards? In this case, should > the default trigger for this assigner not be one with a > TriggerResult.FIRE_AND_PURGE? > > Would be happy to file a bug and/or produce a PR for this but wanted to > check with the list first to make sure I'm not missing anything here. > > Thanks, > Urs > > -- > Urs Schönenberger * urs.schoenenber...@tngtech.com > TNG Technology Consulting GmbH, Beta-Str. 13a, 85774 Unterföhring > Geschäftsführer: Henrik Klagges, Dr. Robert Dahlke, Thomas Endres > Aufsichtsratsvorsitzender: Christoph Stock > Sitz: Unterföhring * Amtsgericht München * HRB 135082 >
