Question on Testing

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Question on Testing

Chenguang He-2
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
Reply | Threaded
Open this post in threaded view
|

Re: Question on Testing

Nick Dimiduk
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 <[hidden email]> 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
>