You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/06/10 18:22:11 UTC
[3/4] storm git commit: STORM-1705: Fix cap-retry bug
STORM-1705: Fix cap-retry bug
Signed-off-by: P. Taylor Goetz <pt...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a8430b38
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a8430b38
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a8430b38
Branch: refs/heads/1.0.x-branch
Commit: a8430b38f952d3473c3d3a00a5598a14af159393
Parents: 952ef33
Author: Abhishek Agarwal <ab...@inmobi.com>
Authored: Fri Jun 10 21:18:40 2016 +0530
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri Jun 10 13:59:58 2016 -0400
----------------------------------------------------------------------
.../org/apache/storm/kafka/ExponentialBackoffMsgRetryManager.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/a8430b38/external/storm-kafka/src/jvm/org/apache/storm/kafka/ExponentialBackoffMsgRetryManager.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/ExponentialBackoffMsgRetryManager.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/ExponentialBackoffMsgRetryManager.java
index b2cfaf0..cacf73c 100644
--- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/ExponentialBackoffMsgRetryManager.java
+++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/ExponentialBackoffMsgRetryManager.java
@@ -106,7 +106,6 @@ public class ExponentialBackoffMsgRetryManager implements FailedMsgRetryManager
MessageRetryRecord record = this.records.get(offset);
return ! (record != null &&
this.retryLimit > 0 &&
- this.waiting.contains(record) &&
this.retryLimit <= record.retryNum);
}