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:38 UTC
[17/44] storm git commit: silly fix
silly fix
use member var, don't pass it
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f4fa76c6
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f4fa76c6
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f4fa76c6
Branch: refs/heads/master
Commit: f4fa76c63efefa987ba124dd7dc8f895f9fe6dcc
Parents: 2aa0346
Author: Rick Kilgore <ri...@hbo.com>
Authored: Tue Sep 9 16:06:56 2014 -0700
Committer: Rick Kilgore <ri...@hbo.com>
Committed: Tue Sep 9 16:06:56 2014 -0700
----------------------------------------------------------------------
external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/f4fa76c6/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 c66545e..36a0e85 100644
--- a/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
+++ b/external/storm-kafka/src/jvm/storm/kafka/PartitionManager.java
@@ -307,15 +307,15 @@ public class PartitionManager {
private MessageRetryRecord(int retryNum) {
this.retryNum = retryNum;
- this.retryTimeUTC = new Date().getTime() + calculateRetryDelay(this.retryNum);
+ this.retryTimeUTC = new Date().getTime() + calculateRetryDelay();
}
public MessageRetryRecord createNextRetryRecord() {
return new MessageRetryRecord(this.retryNum + 1);
}
- private long calculateRetryDelay(int retryNum) {
- double delayMultiplier = Math.pow(_spoutConfig.retryDelayMultiplier, retryNum - 1);
+ private long calculateRetryDelay() {
+ double delayMultiplier = Math.pow(_spoutConfig.retryDelayMultiplier, this.retryNum - 1);
long delayThisRetryMs = (long) (_spoutConfig.retryInitialDelayMs * delayMultiplier);
return Math.min(delayThisRetryMs, _spoutConfig.retryDelayMaxMs);
}