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.

Reply via email to