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/01/14 16:44:35 UTC
[2/4] storm git commit: STORM-600: fixed a test that had some issues
with scheduling order
STORM-600: fixed a test that had some issues with scheduling order
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/41d1d9c0
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/41d1d9c0
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/41d1d9c0
Branch: refs/heads/master
Commit: 41d1d9c0ef72db56c18fb1cc422f4dd949b32138
Parents: e5f2370
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Mon Dec 22 16:52:33 2014 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Mon Dec 22 16:52:33 2014 -0600
----------------------------------------------------------------------
.../clj/backtype/storm/scheduler/multitenant_scheduler_test.clj | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/41d1d9c0/storm-core/test/clj/backtype/storm/scheduler/multitenant_scheduler_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/scheduler/multitenant_scheduler_test.clj b/storm-core/test/clj/backtype/storm/scheduler/multitenant_scheduler_test.clj
index 049a0d6..856121f 100644
--- a/storm-core/test/clj/backtype/storm/scheduler/multitenant_scheduler_test.clj
+++ b/storm-core/test/clj/backtype/storm/scheduler/multitenant_scheduler_test.clj
@@ -622,6 +622,8 @@
(is (= 4 (.size assigned-slots)))
(is (= 2 (.size (into #{} (for [slot assigned-slots] (.getNodeId slot))))))
)
+ ;;The text can be off for a bit until we schedule again
+ (.scheduleAsNeeded isolated-pool (into-array NodePool [free-pool]))
(is (= "Max Nodes(2) for this user would be exceeded. 1 more nodes needed to run topology." (.get (.getStatusMap cluster) "topology1")))
(is (= "Scheduled Isolated on 2 Nodes" (.get (.getStatusMap cluster) "topology2")))
))