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/nimbus-ha-branch Commit: aa24375258626ed6cb3db5257ebc6b7708558bb0 Parents: 4502bff Author: Parth Brahmbhatt <[email protected]> Authored: Thu Feb 12 12:01:52 2015 -0800 Committer: Parth Brahmbhatt <[email protected]> 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
