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

Reply via email to