storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kabh...@apache.org
Subject [2/5] storm git commit: Update timer.clj
Date Tue, 25 Aug 2015 00:24:04 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/a3b29e00
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a3b29e00
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a3b29e00

Branch: refs/heads/master
Commit: a3b29e005f11d184b8cfe6a53f75f667bf2bec68
Parents: d1a6f4a
Author: Li Wang <wangli1426@gmail.com>
Authored: Thu Aug 13 11:45:40 2015 +0800
Committer: Li Wang <wangli1426@gmail.com>
Committed: Thu Aug 13 11:45:40 2015 +0800

----------------------------------------------------------------------
 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/a3b29e00/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