You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2014/07/29 22:58:02 UTC
[03/50] git commit: STORM-403: heartbeats-to-nimbus in
supervisor-test failed due to unintentional worker launch
STORM-403: heartbeats-to-nimbus in supervisor-test failed due to unintentional worker launch
Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/e6d138e1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/e6d138e1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/e6d138e1
Branch: refs/heads/security
Commit: e6d138e1935ad77099ea8513a1ea3d6141beec82
Parents: 96e81c1
Author: iwasakims <iw...@example.com>
Authored: Wed Jul 16 06:26:15 2014 -0700
Committer: iwasakims <iw...@example.com>
Committed: Wed Jul 16 06:26:15 2014 -0700
----------------------------------------------------------------------
.../test/clj/backtype/storm/supervisor_test.clj | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/e6d138e1/storm-core/test/clj/backtype/storm/supervisor_test.clj
----------------------------------------------------------------------
diff --git a/storm-core/test/clj/backtype/storm/supervisor_test.clj b/storm-core/test/clj/backtype/storm/supervisor_test.clj
index eb69f11..1a27c1a 100644
--- a/storm-core/test/clj/backtype/storm/supervisor_test.clj
+++ b/storm-core/test/clj/backtype/storm/supervisor_test.clj
@@ -229,16 +229,16 @@
{"1" (thrift/mk-spout-spec (TestPlannerSpout. true) :parallelism-hint 4)}
{}))
;; prevent them from launching by capturing them
- (capture-changed-workers (submit-local-topology (:nimbus cluster) "test" {TOPOLOGY-WORKERS 2} topology))
- (advance-cluster-time cluster 3)
- (check-heartbeat cluster "sup" 3)
- (advance-cluster-time cluster 3)
- (check-heartbeat cluster "sup" 3)
- (advance-cluster-time cluster 3)
- (check-heartbeat cluster "sup" 3)
- (advance-cluster-time cluster 20)
- (check-heartbeat cluster "sup" 3)
-
+ (capture-changed-workers
+ (submit-local-topology (:nimbus cluster) "test" {TOPOLOGY-WORKERS 2} topology)
+ (advance-cluster-time cluster 3)
+ (check-heartbeat cluster "sup" 3)
+ (advance-cluster-time cluster 3)
+ (check-heartbeat cluster "sup" 3)
+ (advance-cluster-time cluster 3)
+ (check-heartbeat cluster "sup" 3)
+ (advance-cluster-time cluster 20)
+ (check-heartbeat cluster "sup" 3))
)))
(deftest test-worker-launch-command