fix

Change-Id: Id751e63ddd20ca6223d83d8057623f19e54fa3ca

Author: guyinyou

store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java

@@ -1840,10 +1840,14 @@ public void flush() throws IOException {
             synchronized (lockWhenFlush) {
                 prepareTimerCheckPoint();
                 timerLog.getMappedFileQueue().flush(0);
-                if (System.currentTimeMillis() - lastSnapshotTime > storeConfig.getTimerWheelSnapshotIntervalMs()) {
-                    lastSnapshotTime = System.currentTimeMillis();
-                    timerWheel.backup(timerLog.getMappedFileQueue().getFlushedWhere());
-                    timerCheckpoint.flush();
+                if (storeConfig.isTimerWheelSnapshotFlush()) {
+                    if (System.currentTimeMillis() - lastSnapshotTime > storeConfig.getTimerWheelSnapshotIntervalMs()) {
+                        lastSnapshotTime = System.currentTimeMillis();
+                        timerWheel.backup(timerLog.getMappedFileQueue().getFlushedWhere());
+                        timerCheckpoint.flush();
+                    }
+                } else {
+                    timerWheel.flush();
                 }
             }
             if (System.currentTimeMillis() - start > storeConfig.getTimerProgressLogIntervalMs()) {