STORM-1705: Fix cap-retry bug Signed-off-by: P. Taylor Goetz <[email protected]>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ded5a0df Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ded5a0df Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ded5a0df Branch: refs/heads/master Commit: ded5a0df1510313ae2dce8869dbabaad6567452d Parents: 5824189 Author: Abhishek Agarwal <[email protected]> Authored: Fri Jun 10 21:18:40 2016 +0530 Committer: P. Taylor Goetz <[email protected]> Committed: Fri Jun 10 14:02:02 2016 -0400 ---------------------------------------------------------------------- .../org/apache/storm/kafka/ExponentialBackoffMsgRetryManager.java | 1 - 1 file changed, 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/ded5a0df/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); }
