Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2669#discussion_r188055726
--- Diff:
storm-client/src/jvm/org/apache/storm/messaging/netty/Context.java ---
@@ -65,20 +65,8 @@ public synchronized IConnection bind(String storm_id,
int port) {
* establish a connection to a remote server
*/
public synchronized IConnection connect(String storm_id, String host,
int port, AtomicBoolean[] remoteBpStatus) {
--- End diff --
This no longer needs to be synchronized. That was used to protect
connections, and is no longer needed if all we do is create a new Client.
---
