Hi,I just realized that user state acquired via StateInternals in the Flink Runner is not released automatically even when it falls out of the Window scope. There are ways to work around this, i.e. setting a cleanup timer that fires when the Window expires.
Do we expect Runners to perform the cleanup? I would think so since users do not have control over state once the window expires.
Thanks, Max
