As I know, each TaskManager has NettyConnectionManager component and  all the 
tasks in the TaskManager will user  that to transfer data. In the 
PartitionRequestClientFactory, the nettyClient will make a connection based on 
connectionId, and the connectionId consists of socketAddress and 
connectionIndex of IntermediateResult. That means for different 
IntermediateResult, it will create different connection to transfer data in the 
same TaskManager. I am wondering why can not use the same channel for different 
intermediateResult to transfer data. Are there any issues?
Thank you in advance for any suggestions!
Best wishes,
Zhijiang Wang

Reply via email to