Description
In init method of AbstractMessageManager, the following codes found:
public void init(TaskAttemptID attemptId, BSPPeer<?, ?, ?, ?, M> peer, Configuration conf, InetSocketAddress peerAddress) { ... this.peerAddress = peerAddress; this.localQueue = getSenderQueue(); this.localQueueForNextIteration = getSynchronizedReceiverQueue(); this.maxCachedConnections = conf.getInt(MAX_CACHED_CONNECTIONS_KEY, 100); }
The localQueue should be a receiveQueue but it is assigned here, should it be changed as following?:
this.localQueue = getSynchronizedReceiverQueue();
Is there any special purpose here when set it as senderQueue?