Fix issue 165
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/cf723ad4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/cf723ad4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/cf723ad4 Branch: refs/heads/master Commit: cf723ad4e4dc6f2d57e123e5fe1485a191f27597 Parents: 55b5570 Author: Li Zhanhui <[email protected]> Authored: Thu Apr 6 16:43:52 2017 +0800 Committer: dongeforever <[email protected]> Committed: Tue Jun 6 11:37:29 2017 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/cf723ad4/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java ---------------------------------------------------------------------- diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index 5c2d27f..0edfeec 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -462,7 +462,7 @@ public class DefaultMessageStore implements MessageStore { long maxPhyOffsetPulling = 0; int i = 0; - final int maxFilterMessageCount = 16000; + final int maxFilterMessageCount = Math.max(16000, maxMsgNums * ConsumeQueue.CQ_STORE_UNIT_SIZE); final boolean diskFallRecorded = this.messageStoreConfig.isDiskFallRecorded(); for (; i < bufferConsumeQueue.getSize() && i < maxFilterMessageCount; i += ConsumeQueue.CQ_STORE_UNIT_SIZE) { long offsetPy = bufferConsumeQueue.getByteBuffer().getLong();
