Re: Unexpected TestStream behavior when testing stateful DoFn

2019-04-09 Thread Amar Pai
Thanks, will do! -Amar On Tue, Apr 9, 2019 at 5:46 PM Pablo Estrada wrote: > I've added your snippet as a unit test, and fixed that test[1] : ) - > thanks for reporting the issue. Please let me know if you see any other > issues like this. > Best > -P. > > [1]

Re: Unexpected TestStream behavior when testing stateful DoFn

2019-04-09 Thread Pablo Estrada
I've added your snippet as a unit test, and fixed that test[1] : ) - thanks for reporting the issue. Please let me know if you see any other issues like this. Best -P. [1] https://github.com/apache/beam/pull/8252 On Thu, Apr 4, 2019 at 2:46 PM Pablo Estrada wrote: > I saw similar issues. I'll

Re: Unexpected TestStream behavior when testing stateful DoFn

2019-04-04 Thread Pablo Estrada
I saw similar issues. I'll try to debug this tomorrow. It'll take some time to study the code, so we'll see. Assigning the issue to me. On Fri, Mar 29, 2019 at 6:43 AM Steve Niemitz wrote: > This reminds me of a bug I had filed for the direct runner a few weeks > ago, except I was running into

Re: Unexpected TestStream behavior when testing stateful DoFn

2019-03-29 Thread Steve Niemitz
This reminds me of a bug I had filed for the direct runner a few weeks ago, except I was running into it in Java and not python. https://issues.apache.org/jira/browse/BEAM-6813 On Thu, Mar 28, 2019 at 9:04 PM Ahmet Altay wrote: > I agree it looks like a bug. Filed >

Re: Unexpected TestStream behavior when testing stateful DoFn

2019-03-28 Thread Ahmet Altay
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: > This looks like a bug to me. > > On Thu, Mar 28, 2019 at 2:52 PM Amar Pai wrote: > >> Hi, >> >> I'm running into some unexpected behavior when trying to unit

Re: Unexpected TestStream behavior when testing stateful DoFn

2019-03-28 Thread Reuven Lax
This looks like a bug to me. On Thu, Mar 28, 2019 at 2:52 PM Amar Pai wrote: > 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: >