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

Reply via email to