Hi, I have a unit test using TestStream. It worked fine, until I added a Timer to the pipeline I'm testing, and now it hangs after seemingly finishing correctly.
I've put together a minimal example at https://github.com/andrewrjones/beam-test-stream-timer/blob/master/src/test/java/com/andrewjones/beam/TimerTest.java. I notice when I use the following, it hangs: .addElements(KV.of("hello", 100)) .addElements(KV.of("hello", 200)) However, this seems to be fine: .addElements(KV.of("hello", 100), KV.of("hello", 200)) In both cases the code seems to work as expected, judging by the calls to println. Is this a problem with TestStream? Or should I not have KVs with the same Key when using a Timer? Thanks, Andrew
