Is this not already handled by cleanupTimer in StatefulDoFnRunner? 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. > > Thanks, > Max > >
