You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Chris Miller <cm...@34s.de> on 2018/10/11 08:54:33 UTC

What are channels mapped to?

 

Hi, 

in the OutputEmitter, the output channel can be selected in different
manner. 

eg. OutputEmitter#hashPartitionDefault() 

What are the channels mapped to? Do they map to one IP Address or Port? 

Thanks. 

Chris

回复：What are channels mapped to?

Posted by "Zhijiang(wangzhijiang999)" <wa...@aliyun.com>.

The channels are mapped to the subpartition index which would be consumed by specific downstream task parallelism.

For example, if there are three reduce tasks parallelism, every map task would generate three subpartitions. If one record is hashed to the first channel, that means this record will be consumed by the first reduce task.

Best,
Zhijiang
------------------------------------------------------------------
发件人：Chris Miller <cm...@34s.de>
发送时间：2018年10月11日(星期四) 16:54
收件人：user <us...@flink.apache.org>
主　题：What are channels mapped to?

Hi,
in the OutputEmitter, the output channel can be selected in different manner. 
eg. OutputEmitter#hashPartitionDefault()
What are the channels mapped to? Do they map to one IP Address or Port?
Thanks.
Chris