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 -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Multiple-consumers-on-a-subpartition-tp12809.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
