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 at 7:21 PM Marie May <bigmoo...@gmail.com> wrote: > 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? >
