Github user asfgit closed the pull request at:
https://github.com/apache/storm/pull/2669
---
Github user pczb commented on a diff in the pull request:
https://github.com/apache/storm/pull/2669#discussion_r18812
--- Diff: storm-client/src/jvm/org/apache/storm/messaging/IContext.java ---
@@ -38,6 +38,7 @@
/**
* This method establishes a server
Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2669#discussion_r188377925
--- Diff: storm-client/src/jvm/org/apache/storm/messaging/IContext.java ---
@@ -38,6 +38,7 @@
/**
* This method establishes a server
Github user pczb commented on a diff in the pull request:
https://github.com/apache/storm/pull/2669#discussion_r188355473
--- Diff: storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java
---
@@ -451,7 +451,6 @@ public int getPort() {
public void close() {
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2669#discussion_r188055495
--- Diff: storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java
---
@@ -451,7 +451,6 @@ public int getPort() {
public void close() {
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2669#discussion_r188056330
--- Diff:
storm-client/src/jvm/org/apache/storm/messaging/netty/Context.java ---
@@ -65,20 +65,8 @@ public synchronized IConnection bind(String storm_id,
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,
GitHub user pczb opened a pull request:
https://github.com/apache/storm/pull/2669
[STORM-3055] remove conext connection cache
workerState has already cache connection use supervisor_id + port
and if context and worker both cache connection, there can be some problem
describe in
