You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by do...@apache.org on 2017/06/06 03:38:35 UTC
[15/51] [abbrv] incubator-rocketmq git commit: Fix issue 165
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 <li...@apache.org>
Authored: Thu Apr 6 16:43:52 2017 +0800
Committer: dongeforever <zh...@yeah.net>
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();