This is an automated email from the ASF dual-hosted git repository.
lollipop pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new ecd78d9958 fix (#9526) Fix combineCQ extra search commitLog files for
recovery
ecd78d9958 is described below
commit ecd78d9958e028a4057fbc2822c6ef93c21e869b
Author: qianye <[email protected]>
AuthorDate: Tue Jul 8 14:10:13 2025 +0800
fix (#9526) Fix combineCQ extra search commitLog files for recovery
Fix combineCQ extra search commitLog files for recovery
---
.../java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java
b/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java
index cbcc941fe9..0454f00294 100644
---
a/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java
+++
b/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java
@@ -153,7 +153,7 @@ public class CombineConsumeQueueStore implements
ConsumeQueueStoreInterface {
continue;
}
// if other store is not matched for fully recovery,
extraSearchCommitLogFilesForRecovery will minus 1
- if (extraSearchCommitLogFilesForRecovery.getAndIncrement() <= 0) {
+ if (extraSearchCommitLogFilesForRecovery.getAndDecrement() <= 0) {
// extraSearchCommitLogFilesForRecovery <= 0, only can read
from assignOffsetStore
if (assignOffsetStore != currentReadStore) {
log.error("CombineConsumeQueueStore currentReadStore not
satisfied readable conditions, assignOffsetStore={}, currentReadStore={}",
