fixes from review replace new Date().getTime() with System.currentTimeMillis()
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/26af8daa Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/26af8daa Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/26af8daa Branch: refs/heads/master Commit: 26af8daa3e16e2199828c7760a68849dbbd27af1 Parents: f4fa76c Author: Rick Kilgore <[email protected]> Authored: Wed Sep 10 16:05:36 2014 -0700 Committer: Rick Kilgore <[email protected]> Committed: Wed Sep 10 16:05:36 2014 -0700 ---------------------------------------------------------------------- external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/26af8daa/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java index 36a0e85..6b0930b 100644 --- a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java +++ b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java @@ -307,7 +307,7 @@ public class PartitionManager { private MessageRetryRecord(int retryNum) { this.retryNum = retryNum; - this.retryTimeUTC = new Date().getTime() + calculateRetryDelay(); + this.retryTimeUTC = System.currentTimeMillis() + calculateRetryDelay(); } public MessageRetryRecord createNextRetryRecord() { @@ -321,7 +321,7 @@ public class PartitionManager { } public boolean isReadyForRetry() { - return new Date().getTime() > this.retryTimeUTC; + return System.currentTimeMillis() > this.retryTimeUTC; } } }
