Hi Change,
Try
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
<version>${flink.version}</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
.
On Mon, Aug 13, 2018 at 6:42 PM, Chang Liu <fluency...@gmail.com> wrote:
> And another question: which library should I include in order to use these
> harnesses? I do have this flink-test-utils_2.11 in my pom, but I cannot
> find the harnesses.
>
> I also have the following in my pom:
>
> - flink-core
> - flink-clients_2.11
> - flink-scala_2.11
> - flink-streaming-java_2.11
> - flink-streaming-java_2.11
> - flink-connector-kafka-0.11_2.11
>
>
> Best regards/祝好,
>
> Chang Liu 刘畅
>
>
> On 13 Aug 2018, at 04:01, Hequn Cheng <chenghe...@gmail.com> wrote:
>
> Hi Chang,
>
> There are some harness tests which can be used to test your function. It
> is also a common way to test function or operator in flink internal tests.
> Currently, the harness classes mainly include:
>
> - KeyedOneInputStreamOperatorTestHarness
> - KeyedTwoInputStreamOperatorTestHarness
> - OneInputStreamOperatorTestHarness
> - TwoInputStreamOperatorTestHarness
>
> You can take a look at the source code of these classes.
>
> To be more specific, you can take a look at the
> testSlidingEventTimeWindowsApply[1], in which the RichSumReducer window
> function has been tested.
>
> Best, Hequn
>
> [1] https://github.com/apache/flink/blob/master/flink-
> streaming-java/src/test/java/org/apache/flink/streaming/
> runtime/operators/windowing/WindowOperatorTest.java#L213
>
>
> On Mon, Aug 13, 2018 at 7:10 AM, Chang Liu <fluency...@gmail.com> wrote:
>
>> Dear all,
>>
>> I have some questions regarding testing in Flink. The more general
>> question is: is there any guideline, template, or best practices that we
>> can follow if we want to test our flink code (more in scala)?
>>
>> I know there is this page: https://ci.apache.org/pr
>> ojects/flink/flink-docs-release-1.6/dev/stream/testing.html but not so
>> much written there. And I also did not find a more comprehensive
>> documentation of this library: flink-test-utils_2.11.
>>
>> One detailed question: how do you test this WindowFunction below? The
>> return type is Unit right? We cannot do unit test on like, like how the
>> ReduceFunction was tested in the example link above. Then we only have the
>> option of doing integration testing on it?
>> <code.png>
>>
>>
>> Your ideas would be very helpful :) Thanks in advance !
>>
>> Best regards/祝好,
>>
>> Chang Liu 刘畅
>>
>>
>>
>
>
