You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ki...@apache.org on 2016/03/04 18:44:52 UTC
[1/3] storm git commit: Always try to reconnect disconnected
DRPCInvocationsClient
Repository: storm
Updated Branches:
refs/heads/master db04ce689 -> 595ed28e4
Always try to reconnect disconnected DRPCInvocationsClient
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0bf82362
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0bf82362
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0bf82362
Branch: refs/heads/master
Commit: 0bf82362e110ffaa916e496534b5babb23f0e666
Parents: 9ddd29f
Author: Kishor Patil <kp...@yahoo-inc.com>
Authored: Fri Feb 12 16:48:24 2016 +0000
Committer: Kishor Patil <kp...@yahoo-inc.com>
Committed: Fri Feb 12 16:48:24 2016 +0000
----------------------------------------------------------------------
storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/0bf82362/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java b/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java
index e500c7d..791fc91 100644
--- a/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java
+++ b/storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java
@@ -182,6 +182,8 @@ public class DRPCSpout extends BaseRichSpout {
client = _clients.get(i);
}
if (!client.isConnected()) {
+ LOG.warn("DRPCInvocationsClient [{}:{}] is not connected.", client.getHost(), client.getPort());
+ reconnect(client);
continue;
}
try {
[2/3] storm git commit: Merge branch 'storm1543' of
https://github.com/kishorvpatil/incubator-storm
Posted by ki...@apache.org.
Merge branch 'storm1543' of https://github.com/kishorvpatil/incubator-storm
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1d0ca7be
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1d0ca7be
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1d0ca7be
Branch: refs/heads/master
Commit: 1d0ca7be2ae2631eced20aca94c8bad95ed7d3f0
Parents: db04ce6 0bf8236
Author: Kishor Patil <kp...@yahoo-inc.com>
Authored: Fri Mar 4 17:34:41 2016 +0000
Committer: Kishor Patil <kp...@yahoo-inc.com>
Committed: Fri Mar 4 17:34:41 2016 +0000
----------------------------------------------------------------------
storm-core/src/jvm/org/apache/storm/drpc/DRPCSpout.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
[3/3] storm git commit: Added STORM-1543 ot Changelog
Posted by ki...@apache.org.
Added STORM-1543 ot Changelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/595ed28e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/595ed28e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/595ed28e
Branch: refs/heads/master
Commit: 595ed28e40d122d803aae778fc6750fa7d357007
Parents: 1d0ca7b
Author: Kishor Patil <kp...@yahoo-inc.com>
Authored: Fri Mar 4 17:35:27 2016 +0000
Committer: Kishor Patil <kp...@yahoo-inc.com>
Committed: Fri Mar 4 17:35:27 2016 +0000
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/595ed28e/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index b79340a..bbaec75 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 2.0.0
+ * STORM-1543: DRPCSpout should always try to reconnect disconnected DRPCInvocationsClient
* STORM-1528: Fix CsvPreparableReporter log directory
* STORM-1561: Supervisor should relaunch worker if assignments have changed
* STORM-1283: port backtype.storm.MockAutoCred to java