From 952772fa1bc48bb27b5e0ee586b2b086c2ef611a Mon Sep 17 00:00:00 2001
From: rongtong <jinrongtong5@163.com>
Date: Mon, 24 May 2021 19:47:51 +0800
Subject: [PATCH] fix(dledger): reload the delay offset when master changed
 (#2518)

---
 .../apache/rocketmq/store/schedule/ScheduleMessageService.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java b/store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
index a78c5f8a..bacae1e8 100644
--- a/store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
@@ -112,6 +112,7 @@ public class ScheduleMessageService extends ConfigManager {
 
     public void start() {
         if (started.compareAndSet(false, true)) {
+            super.load();
             this.timer = new Timer("ScheduleMessageTimerThread", true);
             for (Map.Entry<Integer, Long> entry : this.delayLevelTable.entrySet()) {
                 Integer level = entry.getKey();
-- 
GitLab