Skip to content
Browse files

Merge branch 'master' into 0.9.0

  • Loading branch information...
2 parents 1f1511e + a39add8 commit fd3d4c9e34f5437dce1780fb8a4ce3025f992fdd @nathanmarz committed Dec 19, 2012
Showing with 7 additions and 0 deletions.
  1. +7 −0 test/clj/backtype/storm/nimbus_test.clj
View
7 test/clj/backtype/storm/nimbus_test.clj
@@ -108,6 +108,11 @@
(is (= dist (multi-set distribution)))
))
+(defn disjoint? [& sets]
+ (let [combined (apply concat sets)]
+ (= (count combined) (count (set combined)))
+ ))
+
(defnk check-consistency [cluster storm-name :assigned? true]
(let [state (:storm-cluster-state cluster)
storm-id (get-storm-id state storm-name)
@@ -217,6 +222,8 @@
(is (= {2 3} (topology-node-distribution state "tester1")))
(is (= {3 2} (topology-node-distribution state "tester2")))
+ (is (apply disjoint? (map (partial topology-nodes state) ["noniso" "tester1" "tester2"])))
+
(check-consistency cluster "tester1")
(check-consistency cluster "tester2")
(check-consistency cluster "noniso")

0 comments on commit fd3d4c9

Please sign in to comment.
Something went wrong with that request. Please try again.