You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2015/08/25 02:24:18 UTC
[2/3] storm git commit: Update timer.clj
Update timer.clj
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/fc47fd27
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/fc47fd27
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/fc47fd27
Branch: refs/heads/0.10.x-branch
Commit: fc47fd27ce2a18a329c6c6ea4ce37ec730df372c
Parents: 29d1ba5
Author: Li Wang <wa...@gmail.com>
Authored: Thu Aug 13 11:45:40 2015 +0800
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Tue Aug 25 09:13:01 2015 +0900
----------------------------------------------------------------------
storm-core/src/clj/backtype/storm/timer.clj | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/fc47fd27/storm-core/src/clj/backtype/storm/timer.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/timer.clj b/storm-core/src/clj/backtype/storm/timer.clj
index 1025b28..2c76ce2 100644
--- a/storm-core/src/clj/backtype/storm/timer.clj
+++ b/storm-core/src/clj/backtype/storm/timer.clj
@@ -57,7 +57,7 @@
;; an upper bound, e.g. 1000 millis, to the
;; sleeping time, to limit the response time
;; for detecting any new event within 1 secs.
- (Time/sleep (max 1000 (- time-millis (current-time-millis))))
+ (Time/sleep (min 1000 (- time-millis (current-time-millis))))
;; Otherwise poll to see if any new event
;; was scheduled. This is, in essence, the
;; response time for detecting any new event