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, <contact....@gmail.com> 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 >
