You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by da...@apache.org on 2015/10/30 22:17:55 UTC
[04/12] storm git commit: Update unit test
Update unit test
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3688fa80
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3688fa80
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3688fa80
Branch: refs/heads/master
Commit: 3688fa80416fd8b8422a52c4754fdca9000c603d
Parents: bed92d6
Author: zhuol <zh...@yahoo-inc.com>
Authored: Thu Oct 29 15:09:18 2015 -0500
Committer: zhuol <zh...@yahoo-inc.com>
Committed: Thu Oct 29 15:36:07 2015 -0500
----------------------------------------------------------------------
.../storm/scheduler/resource_aware_scheduler_test.clj | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/3688fa80/storm-core/test/clj/backtype/storm/scheduler/resource_aware_scheduler_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/scheduler/resource_aware_scheduler_test.clj b/storm-core/test/clj/backtype/storm/scheduler/resource_aware_scheduler_test.clj
index bd097a5..aec297d 100644
--- a/storm-core/test/clj/backtype/storm/scheduler/resource_aware_scheduler_test.clj
+++ b/storm-core/test/clj/backtype/storm/scheduler/resource_aware_scheduler_test.clj
@@ -171,7 +171,7 @@
(is (= 1 (.size assigned-slots)))
(is (= 1 (.size (into #{} (for [slot assigned-slots] (.getNodeId slot))))))
(is (= 2 (.size executors))))
- (is (= "topology1 Fully Scheduled" (.get (.getStatusMap cluster) "topology1")))))
+ (is (= "Fully Scheduled" (.get (.getStatusMap cluster) "topology1")))))
(deftest test-topology-with-multiple-spouts
(let [builder1 (TopologyBuilder.) ;; a topology with multiple spouts
@@ -230,14 +230,14 @@
(is (= 1 (.size assigned-slots)))
(is (= 1 (.size (into #{} (for [slot assigned-slots] (.getNodeId slot))))))
(is (= 7 (.size executors))))
- (is (= "topology1 Fully Scheduled" (.get (.getStatusMap cluster) "topology1")))
+ (is (= "Fully Scheduled" (.get (.getStatusMap cluster) "topology1")))
(let [assignment (.getAssignmentById cluster "topology2")
assigned-slots (.getSlots assignment)
executors (.getExecutors assignment)]
(is (= 1 (.size assigned-slots)))
(is (= 1 (.size (into #{} (for [slot assigned-slots] (.getNodeId slot))))))
(is (= 2 (.size executors))))
- (is (= "topology2 Fully Scheduled" (.get (.getStatusMap cluster) "topology2")))))
+ (is (= "Fully Scheduled" (.get (.getStatusMap cluster) "topology2")))))
(deftest test-topology-set-memory-and-cpu-load
(let [builder (TopologyBuilder.)
@@ -273,7 +273,7 @@
(is (= 1 (.size assigned-slots)))
(is (= 1 (.size (into #{} (for [slot assigned-slots] (.getNodeId slot))))))
(is (= 2 (.size executors))))
- (is (= "topology2 Fully Scheduled" (.get (.getStatusMap cluster) "topology2")))))
+ (is (= "Fully Scheduled" (.get (.getStatusMap cluster) "topology2")))))
(deftest test-resource-limitation
(let [builder (TopologyBuilder.)
@@ -335,7 +335,7 @@
(is (>= avail used)))
(doseq [[avail used] cpu-avail->used] ;; for each node, assigned cpu smaller than total
(is (>= avail used))))
- (is (= "topology1 Fully Scheduled" (.get (.getStatusMap cluster) "topology1")))))
+ (is (= "Fully Scheduled" (.get (.getStatusMap cluster) "topology1")))))
(deftest test-scheduling-resilience
(let [supers (gen-supervisors 2 2)