(rocketmq) branch develop updated: [ISSUE #10079] FlushConsumeQueueService: always flush store checkpoint after CQ flush (#10080)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong 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 c197e50f8d [ISSUE #10079] FlushConsumeQueueService: always flush store 
checkpoint after CQ flush (#10080)
c197e50f8d is described below

commit c197e50f8d55f3590b83f4ecb01db04778fc6812
Author: guyinyou <36399867+guyin...@users.noreply.github.com>
AuthorDate: Mon Feb 9 17:38:03 2026 +0800

    [ISSUE #10079] FlushConsumeQueueService: always flush store checkpoint 
after CQ flush (#10080)
    
    Change-Id: I57c0922bb81c2d43359867e82a92fdf2deab7ad7
    
    Co-authored-by: guyinyou <guyinyou....@alibaba-inc.com>
---
 .../main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java 
b/store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java
index 992bfb668c..8c1cb03d18 100644
--- a/store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java
@@ -651,14 +651,12 @@ public class ConsumeQueueStore extends 
AbstractConsumeQueueStore {
                 logicsMsgTimestamp = 
messageStore.getStoreCheckpoint().getTmpLogicsMsgTimestamp();
             }
 
-            boolean flushOK = true;
             for (ConcurrentMap<Integer, ConsumeQueueInterface> maps : 
consumeQueueTable.values()) {
                 for (ConsumeQueueInterface cq : maps.values()) {
                     boolean result = false;
                     for (int i = 0; i < retryTimes && !result; i++) {
                         result = flush(cq, flushConsumeQueueLeastPages);
                     }
-                    flushOK &= result;
                 }
             }
 
@@ -666,7 +664,7 @@ public class ConsumeQueueStore extends 
AbstractConsumeQueueStore {
                 
messageStore.getCompactionStore().flush(flushConsumeQueueLeastPages);
             }
 
-            if (flushOK && 0 == flushConsumeQueueLeastPages) {
+            if (0 == flushConsumeQueueLeastPages) {
                 if (logicsMsgTimestamp > 0) {
                     
messageStore.getStoreCheckpoint().setLogicsMsgTimestamp(logicsMsgTimestamp);
                 }