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 2016/04/01 16:07:39 UTC
[16/35] storm git commit: sdf
sdf
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cc95d4f7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cc95d4f7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cc95d4f7
Branch: refs/heads/master
Commit: cc95d4f708efa123e5fc908bea15545f7139655b
Parents: 95bf673
Author: xiaojian.fxj <xi...@alibaba-inc.com>
Authored: Fri Mar 11 08:03:00 2016 +0800
Committer: xiaojian.fxj <xi...@alibaba-inc.com>
Committed: Fri Mar 11 08:03:00 2016 +0800
----------------------------------------------------------------------
storm-core/src/clj/org/apache/storm/testing.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/cc95d4f7/storm-core/src/clj/org/apache/storm/testing.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/org/apache/storm/testing.clj b/storm-core/src/clj/org/apache/storm/testing.clj
index d2d2671..7804747 100644
--- a/storm-core/src/clj/org/apache/storm/testing.clj
+++ b/storm-core/src/clj/org/apache/storm/testing.clj
@@ -296,7 +296,7 @@
[(:nimbus cluster-map)]
; because a worker may already be dead
workers)]
- (while-timeout timeout-ms (or (not (every? (memfn isWaiting?) daemons))
+ (while-timeout timeout-ms (or (not (every? (memfn isWaiting) daemons))
(not (every? is-supervisor-waiting supervisors)))
(Thread/sleep (rand-int 20))
;; (doseq [d daemons]