Re: [Flink Unit Tests] Unit test for Flink streaming codes

Posted by Vijayendra Yadav on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-Unit-Tests-Unit-test-for-Flink-streaming-codes-tp37119p37122.html

Thank You Niels. Would you have something for the scala object class.  Say for example if I want to implement a unit test ( not integration test) for below code or similar  :

https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/socket/SocketWindowWordCount.scala

Regards,

Vijay

On Fri, Jul 31, 2020 at 12:22 PM Niels Basjes <[hidden email]> wrote:

Does this test in one of my own projects do what you are looking for?

https://github.com/nielsbasjes/yauaa/blob/1e1ceb85c507134614186e3e60952112a2daabff/udfs/flink/src/test/java/nl/basjes/parse/useragent/flink/TestUserAgentAnalysisMapperClass.java#L107

On Fri, 31 Jul 2020, 20:20 Vijayendra Yadav, <[hidden email]> wrote:

Hi Team,

Looking for some help and reference code / material to implement unit tests of possible scenarios in Flink streaming Code that should assert specific cases.

Regards,

Vijay