Unexpected TestStream behavior when testing stateful DoFn

Hi, I'm running into some unexpected behavior when trying to unit test a stateful DoFn that uses watermark timers as well as bag state. I'm following the example here: https://github.com/apache/beam/blob/master/sdks/python/apache_beam/transforms/userstate_test.py#L333 Expected behavior: When

Re: Unexpected TestStream behavior when testing stateful DoFn

2019 at 9:04 PM Ahmet Altay wrote: >>> >>>> I agree it looks like a bug. Filed >>>> https://issues.apache.org/jira/browse/BEAM-6934 >>>> >>>> >>>> >>>> On Thu, Mar 28, 2019 at 5:18 PM Reuven Lax wrote: >&g