fix test

apache · Jan 22, 2025 · 593307f · 593307f
1 parent 8e155e3
commit 593307f
Showing 1 changed file with 3 additions and 3 deletions.
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()));