mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-04 03:40:13 -06:00
Code Issues Packages Projects Releases Wiki Activity

Revert "resume can be executed on other dble nodes (#2361)"

Browse Source 
This reverts commit 2b8d98c5fa.
This commit is contained in:
yanhuqing
2020-12-02 18:30:09 +08:00
parent 2b8d98c5fa
commit d76cde9dce
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/actiontech/dble/services/manager/response/PauseEnd.java
View File

@@ -7,8 +7,10 @@ package com.actiontech.dble.services.manager.response;
import com.actiontech.dble.DbleServer;
import com.actiontech.dble.cluster.ClusterHelper;
import com.actiontech.dble.cluster.ClusterPathUtil;
import com.actiontech.dble.cluster.values.PauseInfo;
import com.actiontech.dble.config.ErrorCode;
import com.actiontech.dble.config.model.ClusterConfig;
import com.actiontech.dble.config.model.SystemConfig;
import com.actiontech.dble.net.mysql.OkPacket;
import com.actiontech.dble.services.manager.ManagerService;
import com.actiontech.dble.singleton.PauseShardingNodeManager;
@@ -51,6 +53,12 @@ public final class PauseEnd {
return;
}
PauseInfo pauseInfo = new PauseInfo(value);
if (!pauseInfo.getFrom().equals(SystemConfig.getInstance().getInstanceName())) {
service.writeErrMessage(ErrorCode.ER_UNKNOWN_ERROR, "This node is not the node which start pause");
return;
}
if (!PauseShardingNodeManager.getInstance().tryResume()) {
OK.setMessage(("No shardingNode paused, But still notify cluster").getBytes());
return;