You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by xi...@apache.org on 2017/07/18 07:45:00 UTC
[6/7] storm git commit: add test for specific owner
add test for specific owner
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/02f2b770
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/02f2b770
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/02f2b770
Branch: refs/heads/master
Commit: 02f2b7705dd584e806730225856cafad8c70125d
Parents: e5d6d32
Author: Ethan Li <et...@gmail.com>
Authored: Mon Jul 17 17:41:17 2017 -0500
Committer: Ethan Li <et...@gmail.com>
Committed: Mon Jul 17 17:41:17 2017 -0500
----------------------------------------------------------------------
.../test/clj/org/apache/storm/nimbus_test.clj | 21 +++++++++++++++++---
1 file changed, 18 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/02f2b770/storm-core/test/clj/org/apache/storm/nimbus_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/org/apache/storm/nimbus_test.clj b/storm-core/test/clj/org/apache/storm/nimbus_test.clj
index c01babb..5c4e0d7 100644
--- a/storm-core/test/clj/org/apache/storm/nimbus_test.clj
+++ b/storm-core/test/clj/org/apache/storm/nimbus_test.clj
@@ -965,13 +965,13 @@
TOPOLOGY-EVENTLOGGER-EXECUTORS 0
})))]
(letlocals
- ;test for 0-topology case
+ ;;test for 0-topology case
(.advanceClusterTime cluster 11)
(bind owner-resource-summaries (.getOwnerResourceSummaries (.getNimbus cluster) nil))
(bind summary (first owner-resource-summaries))
(is (nil? summary))
- ;test for 1-topology case
+ ;;test for 1-topology case
(bind topology (Thrift/buildTopology
{"1" (Thrift/prepareSpoutDetails
(TestPlannerSpout. true) (Integer. 3))}
@@ -988,7 +988,7 @@
(is (= (.get_total_executors summary)) 3)
(is (= (.get_total_topologies summary)) 1)
- ;test for many-topology case
+ ;;test for many-topology case
(bind topology2 (Thrift/buildTopology
{"2" (Thrift/prepareSpoutDetails
(TestPlannerSpout. true) (Integer. 4))}
@@ -1014,6 +1014,21 @@
(is (= (.get_total_workers summary) 10))
(is (= (.get_total_executors summary)) 12)
(is (= (.get_total_topologies summary)) 3)
+
+ ;;test for specific owner
+ (bind owner-resource-summaries (.getOwnerResourceSummaries (.getNimbus cluster) (System/getProperty "user.name")))
+ (bind summary (first owner-resource-summaries))
+ (is (= (.get_total_workers summary) 10))
+ (is (= (.get_total_executors summary)) 12)
+ (is (= (.get_total_topologies summary)) 3)
+
+ ;;test for other user
+ (bind other-user (str "not-" (System/getProperty "user.name")))
+ (bind owner-resource-summaries (.getOwnerResourceSummaries (.getNimbus cluster) other-user))
+ (bind summary (first owner-resource-summaries))
+ (is (= (.get_total_workers summary) 0))
+ (is (= (.get_total_executors summary)) 0)
+ (is (= (.get_total_topologies summary)) 0)
)))
(deftest test-rebalance