From 61c7d4753091d359d809fc6913a3dbe4407327fc Mon Sep 17 00:00:00 2001 From: dcy Date: Fri, 13 Sep 2024 17:12:22 +0800 Subject: [PATCH] =?UTF-8?q?inner-2407-supplement=20=EF=BC=9A=20upload=20me?= =?UTF-8?q?tadata=20for=20switch?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dble/services/manager/response/ha/DbGroupHaSwitch.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/java/com/actiontech/dble/services/manager/response/ha/DbGroupHaSwitch.java b/src/main/java/com/actiontech/dble/services/manager/response/ha/DbGroupHaSwitch.java index 6db8f3e7c..28be26a86 100644 --- a/src/main/java/com/actiontech/dble/services/manager/response/ha/DbGroupHaSwitch.java +++ b/src/main/java/com/actiontech/dble/services/manager/response/ha/DbGroupHaSwitch.java @@ -37,6 +37,7 @@ public final class DbGroupHaSwitch { final ReentrantReadWriteLock lock = DbleServer.getInstance().getConfig().getLock(); lock.readLock().lock(); try { + ClusterHelper clusterHelper = ClusterHelper.getInstance(ClusterOperation.HA); HaConfigManager.getInstance().info("added configLock"); PhysicalDbGroup dh = DbleServer.getInstance().getConfig().getDbGroups().get(dbGroupName); if (dh == null) { @@ -59,6 +60,11 @@ public final class DbGroupHaSwitch { try { //dble start in single mode RawJson result = dh.switchMaster(masterName, true); + + if (ClusterConfig.getInstance().isClusterEnable()) { + clusterHelper.setKV(ClusterMetaUtil.getHaStatusPath(dh.getGroupName()), result); + } + HaConfigManager.getInstance().haFinish(id, null, result); } catch (Exception e) { packetResult.setSuccess(false);