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 <[email protected]> Authored: Tue Sep 9 16:06:56 2014 -0700 Committer: Rick Kilgore <[email protected]> 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); }
