Hey Marie,
Why does it seem that you can only use a single instance of CollectSink?
>From the CollectSink constructor signature, it seems that you can pass
host + port to the class. Can't you allocate the CollectSink on different
ports for the different sinks?
Best,
Robert
On Wed, Jun 10, 2020
Hey Everyone,
I am having an issue with how to test a flink job as a whole (rather than
its functions) when there is more than one sink. It seems CollectSink()
will work only for when there is a single instance .addSink method.
Has anyone implemented this successfully? Or is it not possible?
