storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/3] git commit: STORM-403: heartbeats-to-nimbus in supervisor-test failed due to unintentional worker launch
Date Mon, 21 Jul 2014 16:35:20 GMT
Repository: incubator-storm
Updated Branches:
  refs/heads/master 48cc069ae -> c1aed00e0


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/master
Commit: e6d138e1935ad77099ea8513a1ea3d6141beec82
Parents: 96e81c1
Author: iwasakims <iwasakims@example.com>
Authored: Wed Jul 16 06:26:15 2014 -0700
Committer: iwasakims <iwasakims@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


Mime
View raw message