Hi Yee, Yes, AbstractStreamOperatorTestHarness is a good way to test an operator. As for iterator, do you use an IT or an UT test? I think Thread.sleeps may works for an IT test. If you use an UT, you probably need to set time by yourself, similar to setProcessingTime in harness test.
Best, Hequn On Sat, Sep 1, 2018 at 12:20 PM Yee-Ning Cheng <yee.ni...@gmail.com> wrote: > I was able to use the AbstractStreamOperatorTestHarness to write more of a > unit test for windowing operators. However, I'm still trying to figure out > a way to have a "delayed iterator". I tried implementing an iterator that > Thread.sleeps for the interval and passed it to the stream as an input, but > that didn't seem to work, plus I was having issues with serialization if I > enabled checkpointing which seemed like a hassle. > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
