On Wed, Mar 20, 2019 at 6:23 AM Maximilian Michels <[email protected]> wrote:
> 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. > Just to be super clear for anyone not digging in the referenced code: yes, we do. And the code Reuven referenced is utility code that a runner can use to facilitate this, or the runner can do its own thing. Kenn > > Thanks, > Max > >
