flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Nick Dimiduk <ndimi...@gmail.com>
Subject Re: Question on Testing
Date Tue, 26 Apr 2016 16:00:42 GMT
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 <gaoyike@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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message