You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/03/20 22:01:46 UTC
[41/50] [abbrv] storm git commit: Adding cluster-test for nimbus
summary storage.
Adding cluster-test for nimbus summary storage.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/63f29f34
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/63f29f34
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/63f29f34
Branch: refs/heads/0.11.x-branch
Commit: 63f29f349b469746fd1a4507151ec47942e03e58
Parents: 726ce80
Author: Parth Brahmbhatt <br...@gmail.com>
Authored: Thu Feb 12 16:14:14 2015 -0800
Committer: Parth Brahmbhatt <br...@gmail.com>
Committed: Thu Feb 12 16:14:14 2015 -0800
----------------------------------------------------------------------
storm-core/test/clj/backtype/storm/cluster_test.clj | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/63f29f34/storm-core/test/clj/backtype/storm/cluster_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/cluster_test.clj b/storm-core/test/clj/backtype/storm/cluster_test.clj
index b7630b1..85aaf3b 100644
--- a/storm-core/test/clj/backtype/storm/cluster_test.clj
+++ b/storm-core/test/clj/backtype/storm/cluster_test.clj
@@ -213,6 +213,12 @@
(.remove-storm! state "storm1")
(is (= [] (.code-distributor state nil)))
+ (is (= [] (.nimbuses state)))
+ (.add-nimbus-host! state "host:port" nimbusInfo1)
+ (is (= [nimbusInfo1] (.nimbuses state)))
+ (.add-nimbus-host! state "host1:port" nimbusInfo2)
+ (is (= #{nimbusInfo1 nimbusInfo2} (set (.nimbuses state))))
+
;; TODO add tests for task info and task heartbeat setting and getting
(.disconnect state)
)))