Hi Chenguang, I've been using the class StreamingMultipleProgramsTestBase, found in flink-streaming-java test jar as the basis for my integration tests. These tests spin up a flink cluster (and kafka, and hbase, &c) in a single JVM. It's not a perfect integration environment, but it's as close as we can get without leaving maven/failsafe/junit, and lets me assert with confidence that a flow is pumping data from end to end.
BTW, I'm still running 0.10.x, so YMMV. -n On Tue, Apr 26, 2016 at 8:51 AM, Chenguang He <gaoy...@gmail.com> wrote: > Hello guys, > > I have played Flink for a while, i find out that, the testing code and data > are splitted in different part, for example, some code is in different > model with their own test data, but there is a 'flink-tests' model which > includes a lot of test program. > > I am just wondering that, is there any more abstract streaming test > framework implemented in Flink ? > > Thanks > > Chenguang He >
