You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/07/14 21:06:53 UTC
[22/23] storm git commit: Merge branch 'STORM-763' of
https://github.com/eshioji/storm into STORM-839-0.9.x
Merge branch 'STORM-763' of https://github.com/eshioji/storm into STORM-839-0.9.x
STORM-763: nimbus reassigned worker A to another machine, but other worker's netty client can't connect to the new worker A
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/dafbc000
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/dafbc000
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/dafbc000
Branch: refs/heads/0.9.x-branch
Commit: dafbc000d7aa373f3fea6196a13b48c657aafbff
Parents: f382403 20799b2
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Tue Jul 14 13:42:30 2015 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Tue Jul 14 13:42:30 2015 -0500
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/Config.java | 6 -
.../backtype/storm/messaging/netty/Client.java | 479 +++++++------------
.../backtype/storm/messaging/netty/Context.java | 18 +-
.../storm/messaging/netty/MessageBatch.java | 24 +-
.../storm/messaging/netty/MessageBuffer.java | 58 +++
.../netty/StormClientErrorHandler.java | 41 --
.../messaging/netty/StormClientHandler.java | 46 ++
.../netty/StormClientPipelineFactory.java | 2 +-
8 files changed, 291 insertions(+), 383 deletions(-)
----------------------------------------------------------------------