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/08/24 15:52:08 UTC
[23/50] [abbrv] storm git commit: Fixing a broken test.
Fixing a broken test.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/aa243752
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/aa243752
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/aa243752
Branch: refs/heads/master
Commit: aa24375258626ed6cb3db5257ebc6b7708558bb0
Parents: 4502bff
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Thu Feb 12 12:01:52 2015 -0800
Committer: Parth Brahmbhatt <br...@gmail.com>
Committed: Thu Feb 12 12:01:52 2015 -0800
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/daemon/nimbus.clj | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/aa243752/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
index 52ee708..2059c0d 100644
--- a/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/nimbus.clj
@@ -1327,7 +1327,9 @@
(extract-status-str base))]
(when-let [owner (:owner base)] (.set_owner topo-summ owner))
(when-let [sched-status (.get @(:id->sched-status nimbus) id)] (.set_sched_status topo-summ sched-status))
- (.set_replication_count topo-summ (.getReplicationCount (:code-distributor nimbus) id))
+ (.set_replication_count topo-summ (if (:code-distributor nimbus)
+ (.getReplicationCount (:code-distributor nimbus) id)
+ 1))
topo-summ
))]
(ClusterSummary. supervisor-summaries