diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java index f9c270f4cf..12a246a054 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/Constants.java @@ -568,7 +568,7 @@ public final class Constants { /** * heartbeat for zk info length */ - public static final int HEARTBEAT_FOR_ZOOKEEPER_INFO_LENGTH = 7; + public static final int HEARTBEAT_FOR_ZOOKEEPER_INFO_LENGTH = 5; /** diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/ResInfo.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/ResInfo.java index aa8d44fa42..48e0515453 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/ResInfo.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/ResInfo.java @@ -143,13 +143,11 @@ public class ResInfo { } Server masterServer = new Server(); - masterServer.setHost(masterArray[0]); - masterServer.setPort(Integer.parseInt(masterArray[1])); - masterServer.setResInfo(getResInfoJson(Double.parseDouble(masterArray[2]), - Double.parseDouble(masterArray[3]), - Double.parseDouble(masterArray[4]))); - masterServer.setCreateTime(DateUtils.stringToDate(masterArray[5])); - masterServer.setLastHeartbeatTime(DateUtils.stringToDate(masterArray[6])); + masterServer.setResInfo(getResInfoJson(Double.parseDouble(masterArray[0]), + Double.parseDouble(masterArray[1]), + Double.parseDouble(masterArray[2]))); + masterServer.setCreateTime(DateUtils.stringToDate(masterArray[3])); + masterServer.setLastHeartbeatTime(DateUtils.stringToDate(masterArray[4])); return masterServer; }