fix test

wanghuaiyuan · wanghuaiyuan · commit 593307f7dc0e · 2025-01-22T20:24:27.000+08:00
diff --git a/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java b/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java
@@ -357,12 +357,12 @@ private void fetchAndPutTimerRequest() throws InterruptedException {
 
             while (!expired.isEmpty() && !dequeueGetQueue.offer(expired, 100, TimeUnit.MILLISECONDS)) {
             }
-            for (Map.Entry<Integer, List<TimerMessageRecord>> entry : delete.entrySet()) {
-                timerMessageKVStore.deleteAssignRecords(getColumnFamily(entry.getKey()), entry.getValue(), -1);
-            }
             for (Map.Entry<Integer, List<TimerMessageRecord>> entry : increase.entrySet()) {
                 timerMessageKVStore.writeAssignRecords(getColumnFamily(entry.getKey()), entry.getValue(), -1);
             }
+            for (Map.Entry<Integer, List<TimerMessageRecord>> entry : delete.entrySet()) {
+                timerMessageKVStore.deleteAssignRecords(getColumnFamily(entry.getKey()), entry.getValue(), -1);
+            }
             // sync cq read offset
             timerMessageKVStore.writeAssignRecords(getColumnFamily(0), new ArrayList<>(), commitOffset.addAndGet(trs.size()));
 

Original file line number	Diff line number	Diff line change
`@@ -357,12 +357,12 @@ private void fetchAndPutTimerRequest() throws InterruptedException {`
`357`	`357`
`358`	`358`	`while (!expired.isEmpty() && !dequeueGetQueue.offer(expired, 100, TimeUnit.MILLISECONDS)) {`
`359`	`359`	`}`
`360`		`- for (Map.Entry<Integer, List<TimerMessageRecord>> entry : delete.entrySet()) {`
`361`		`- timerMessageKVStore.deleteAssignRecords(getColumnFamily(entry.getKey()), entry.getValue(), -1);`
`362`		`- }`
`363`	`360`	`for (Map.Entry<Integer, List<TimerMessageRecord>> entry : increase.entrySet()) {`
`364`	`361`	`timerMessageKVStore.writeAssignRecords(getColumnFamily(entry.getKey()), entry.getValue(), -1);`
`365`	`362`	`}`
	`363`	`+ for (Map.Entry<Integer, List<TimerMessageRecord>> entry : delete.entrySet()) {`
	`364`	`+ timerMessageKVStore.deleteAssignRecords(getColumnFamily(entry.getKey()), entry.getValue(), -1);`
	`365`	`+ }`
`366`	`366`	`// sync cq read offset`
`367`	`367`	`timerMessageKVStore.writeAssignRecords(getColumnFamily(0), new ArrayList<>(), commitOffset.addAndGet(trs.size()));`
`368`	`368`