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 <[email protected]> Authored: Fri Mar 11 08:03:00 2016 +0800 Committer: xiaojian.fxj <[email protected]> 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]
