Hello,I have created a FLIP for slightly extending the collect() API to support collecting an arbitrary number of streams, to make it more useful for testing complex workflows.
https://cwiki.apache.org/confluence/display/FLINK/FLIP-251%3A+Support+collecting+arbitrary+number+of+streams Looking forward to any feedback. Regards, Chesnay