I believe that stateful DoFn does not yet work with merging windows. This is an open bug in Beam that should be fixed.
On Fri, Sep 8, 2017 at 12:41 PM, Thomas Weise <[email protected]> wrote: > Hi, > > Is there a known limitation in TestStream that causes stateful DoFn not to > work with windows (state is not tracked)? > > The pipeline is: > > TestStream (or Create.of(...)) -> Session Window -> MapElements -> Stateful > DoFn > > With TestStream, only when I remove the session window then state tracks. > Session window functionality seems to works with other transforms though. > > With Create.of(...), pipeline including the window produces expected > result. > > Just checking first.. I can extract relevant pieces into a gist if what I'm > trying is supposed to work. > > Thanks, > Thomas >
