flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Zhijiang(wangzhijiang999)" <wangzhijiang...@aliyun.com>
Subject 回复:What are channels mapped to?
Date Thu, 11 Oct 2018 09:13:56 GMT
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.

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

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?

View raw message