; predictable, and that elements from main stream arrive after elements from
> control stream, or other way around.
>
>
>
> Thanks again,
>
> Tovi
>
>
>
> *From:* Kostas Kloudas [mailto:k.klou...@data-artisans.com]
> *Sent:* יום ה 07 דצמבר 2017 19:11
> *To:
@flink.apache.org
Subject: Re: Testing CoFlatMap correctness
Hi Tovi,
What you need is the TwoInputStreamOperatorTestHarness. This will allow you to
do something like:
TwoInputStreamOperatorTestHarness testHarness =
new TwoInputStreamOperatorTestHarness<>(myoperator);
testHarness
Hi Tovi,
What you need is the TwoInputStreamOperatorTestHarness. This will allow you to
do something like:
TwoInputStreamOperatorTestHarness testHarness =
new TwoInputStreamOperatorTestHarness<>(myoperator);
testHarness.setup();
testHarness.open();
testHarness.processWatermark1(new Water
Hi group,
What is the best practice for testing CoFlatMap operator correctness?
We have two source functions, each emits data to stream, and a connect between
them, and I want to make sure that when streamA element arrive before stream
element, a certain behavior happens.
How can I test this cas
