From cf74c3cd8b0e0b77bceef9a0a4ae6fd7c3b92f79 Mon Sep 17 00:00:00 2001 From: mxsm Date: Mon, 29 Aug 2022 20:42:28 +0800 Subject: [PATCH] [ISSUE #4913] ReplicasManager#schedulingSyncControllerMetadata update controller metadata again after a while (#4914) --- .../apache/rocketmq/broker/controller/ReplicasManager.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java b/broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java index dd0aaa5636..c3afc1a7ca 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java @@ -377,6 +377,11 @@ public class ReplicasManager { if (flag) { this.scheduledService.scheduleAtFixedRate(this::updateControllerMetadata, 1000 * 3, this.brokerConfig.getSyncControllerMetadataPeriod(), TimeUnit.MILLISECONDS); return true; + } + try { + TimeUnit.SECONDS.sleep(1); + } catch (InterruptedException ignore) { + } tryTimes++; }