You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/01/14 17:05:40 UTC
[19/44] storm git commit: fixes from review
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 <ri...@hbo.com>
Authored: Wed Sep 10 16:05:36 2014 -0700
Committer: Rick Kilgore <ri...@hbo.com>
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;
}
}
}