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
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 ther
