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);