Hi albert, As I know, if the upstream data will be consumed by multiple consumers, it will generate multiple subpartitions, and each subpartition will correspond to one input channel consumer.So it is one-to-one correspondence among subpartition -> subpartition view -> input channel. cheers,zhijiang------------------------------------------------------------------发件人：albertjonathan <alb...@cs.umn.edu>发送时间：2017年4月26日(星期三) 02:37收件人：user <user@flink.apache.org>主 题：Multiple consumers on a subpartition 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.
