Github user tgravescs commented on the pull request:
https://github.com/apache/spark/pull/1758#issuecomment-51394255
so looking at your first log it looks like its trying to send a message to
itself in the failed case and in the good case it sends it to the other
connectionManager. Look at the port numbers.
good:
Bound socket to port 58931 with id = ConnectionManagerId(joshs-mbp,58931)
14/08/06 13:09:38.141 INFO ConnectionManager: Bound socket to port 58932
with id = ConnectionManagerId(joshs-mbp,58932)
14/08/06 13:09:38.266 DEBUG SecurityMessage: message total size is : 42
14/08/06 13:09:38.266 DEBUG SendingConnection: Added [BufferMessage(id = 5,
size = 42)] to outbox for sending to [ConnectionManagerId(joshs-mbp,58932)]
Failed:
ager: Bound socket to port 58889 with id =
ConnectionManagerId(joshs-mbp,58889)
14/08/06 13:07:01.260 INFO ConnectionManager: Bound socket to port 58890
with id = ConnectionManagerId(joshs-mbp,58890)
14/08/06 13:07:01.386 DEBUG SecurityMessage: message total size is : 42
14/08/06 13:07:01.387 DEBUG SendingConnection: Added [BufferMessage(id = 5,
size = 42)] to outbox for sending to [ConnectionManagerId(joshs-mbp,58889)]
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
