|
Hello,
Is there a way Flink allow a (pipelined) subpartition to be consumed by multiple consumers? If not, would it make more sense to implement it as multiple input channels for a single subpartition or multiple subpartition views for each input channel?
Any suggestion is appreciated.
Thanks
|