Hi, I'm currently working on improving the testing process of flink streaming applications.
I have written a test runtime that takes care of execution, collecting the output and applying a verifier to it. The runtime is able to provide test sources and sinks that run in parallel. On top of that it offers an API for defining JUnit tests. I have recreated your test using my API: https://gist.github.com/anonymous/8825ea83e8fe9afba19e I have a second example that shows some of the more advanced features of the API and runtime: https://gist.github.com/anonymous/fa5c77becae2e37d28eb Unfortunately It's still a work in progress. But I'm planning to have a first release candidate at the end of the month. Best, Alex -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Published-test-artifacts-for-flink-streaming-tp3379p3584.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
