RE: Unit-testing BEAM pipelines with PROCESSING_TIME timers

2020-05-11 Thread Robert.Butcher
Many thanks, Darshan! I’ve made equivalent changes to my test case and it’s working fine. Kind regards, Rob From: Darshan Jani [mailto:darshanjani...@gmail.com] Sent: 11 May 2020 15:08 To: dev@beam.apache.org Subject: Re: Unit-testing BEAM pipelines with PROCESSING_TIME timers

Re: Unit-testing BEAM pipelines with PROCESSING_TIME timers

2020-05-11 Thread Darshan Jani
Hi Robert, I found this sample test with Timer on processing time. >From the error, I assume there may be is a problem what are you asserting in your PAssert. https://github.com/apache/beam/blob/master/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/ParDoTest.java#L3633-L3665 I ran