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?
