storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [2/3] storm git commit: Update timer.clj
Date Tue, 25 Aug 2015 00:24:18 GMT
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 <wangli1426@gmail.com>
Authored: Thu Aug 13 11:45:40 2015 +0800
Committer: Jungtaek Lim <kabhwan@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


Mime
View raw message