> > Additionally even though I add all necessary dependencies defiend in [1] I > cannot see ProcessFunctionTestHarnesses class. >
That class was added in Flink 1.10 [1]. [1] https://github.com/apache/flink/blame/f765ad09ae2b2aa478c887b988e11e92a8b730bd/flink-streaming-java/src/test/java/org/apache/flink/streaming/util/ProcessFunctionTestHarnesses.java On Fri, Mar 27, 2020 at 10:13 PM KristoffSC <krzysiek.chmielew...@gmail.com> wrote: > Hi, > Im trying to test my RichAsyncFunction implementation with > OneInputStreamOperatorTestHarness based on [1]. I'm using Flink 1.9.2 > > My test setup is: > this.processFunction = new MyRichAsyncFunction(); > this.testHarness = new OneInputStreamOperatorTestHarness<>( > new AsyncWaitOperator<>(processFunction, 2000, 1, > OutputMode.ORDERED)); > > this.testHarness.open(); > > I'm having below exception when calling this.testHarness.open(); > > java.lang.NullPointerException > at java.base/java.util.Objects.requireNonNull(Objects.java:221) > at > > org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.<init>(StreamElementSerializer.java:64) > at > > org.apache.flink.streaming.api.operators.async.AsyncWaitOperator.setup(AsyncWaitOperator.java:142) > at > > org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness.setup(AbstractStreamOperatorTestHarness.java:287) > at > > org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness.setup(AbstractStreamOperatorTestHarness.java:275) > at > > org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness.initializeState(AbstractStreamOperatorTestHarness.java:393) > at > > org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness.initializeState(AbstractStreamOperatorTestHarness.java:300) > at > > org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness.initializeEmptyState(AbstractStreamOperatorTestHarness.java:308) > at > > org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness.open(AbstractStreamOperatorTestHarness.java:483) > > > I will appreciate help with this one. > > Additionally even though I add all necessary dependencies defiend in [1] I > cannot see ProcessFunctionTestHarnesses class. > > Thanks. > > [1] > > https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/testing.html#unit-testing-stateful-or-timely-udfs--custom-operators > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
