flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zhijiang(wangzhijiang999)" <wangzhijiang...@aliyun.com>
Subject 回复:Multiple consumers on a subpartition
Date Wed, 26 Apr 2017 03:58:56 GMT
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.
<albert@cs.umn.edu>发送时间:2017年4月26日(星期三) 02:37收件人:user
<user@flink.apache.org>主 题:Multiple consumers on a subpartition

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.


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.
View raw message