Hey, Maybe it would be a good idea to create somekind of test source for DataStream that allows writing elements to stream directly. Similarly like it’s done for reactive libraries sources. This would make creating tests a lot easier for Flink.
Best Regards, Dom. Wysłane z aplikacji Poczta dla Windows 10 Od: Hequn Cheng Wysłano: sobota, 1 września 2018 17:18 Do: yee.ni...@gmail.com DW: user Temat: Re: API for delayed/scheduled interval input source for integrationtests 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/
