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 <wangli1...@gmail.com> Authored: Thu Aug 13 11:45:40 2015 +0800 Committer: Li Wang <wangli1...@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