Loading docker/docker-compose.yml +1 −0 Original line number Diff line number Diff line Loading @@ -23,6 +23,7 @@ services: - "2181:2181" environment: ZOO_MY_ID: 1 ZOO_4LW_COMMANDS_WHITELIST: srvr,ruok,wchs,cons db: image: postgres container_name: postgres Loading dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/utils/ZooKeeperState.java +7 −7 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ public class ZooKeeperState { private final String host; private final int port; private int minLatency = -1, avgLatency = -1, maxLatency = -1; private float minLatency = -1, avgLatency = -1, maxLatency = -1; private long received = -1; private long sent = -1; private int outStanding = -1; Loading @@ -60,9 +60,9 @@ public class ZooKeeperState { String line = scannerForStat.nextLine(); if (line.startsWith("Latency min/avg/max:")) { String[] latencys = getStringValueFromLine(line).split("/"); minLatency = Integer.parseInt(latencys[0]); avgLatency = Integer.parseInt(latencys[1]); maxLatency = Integer.parseInt(latencys[2]); minLatency = Float.parseFloat(latencys[0]); avgLatency = Float.parseFloat(latencys[1]); maxLatency = Float.parseFloat(latencys[2]); } else if (line.startsWith("Received:")) { received = Long.parseLong(getStringValueFromLine(line)); } else if (line.startsWith("Sent:")) { Loading Loading @@ -165,15 +165,15 @@ public class ZooKeeperState { return port; } public int getMinLatency() { public float getMinLatency() { return minLatency; } public int getAvgLatency() { public float getAvgLatency() { return avgLatency; } public int getMaxLatency() { public float getMaxLatency() { return maxLatency; } Loading dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/utils/ZookeeperMonitor.java +3 −3 Original line number Diff line number Diff line Loading @@ -88,9 +88,9 @@ public class ZookeeperMonitor extends AbstractZKClient { long sent = state.getSent(); long received = state.getReceived(); String mode = state.getMode(); int minLatency = state.getMinLatency(); int avgLatency = state.getAvgLatency(); int maxLatency = state.getMaxLatency(); float minLatency = state.getMinLatency(); float avgLatency = state.getAvgLatency(); float maxLatency = state.getMaxLatency(); int nodeCount = state.getNodeCount(); int status = ok ? 1 : 0; Date date = new Date(); Loading dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/ZookeeperRecord.java +9 −9 Original line number Diff line number Diff line Loading @@ -56,17 +56,17 @@ public class ZookeeperRecord { /** * min Latency */ private int minLatency; private float minLatency; /** * avg Latency */ private int avgLatency; private float avgLatency; /** * max Latency */ private int maxLatency; private float maxLatency; /** * node count Loading @@ -85,7 +85,7 @@ public class ZookeeperRecord { private int state; public ZookeeperRecord(String hostname,int connections, int watches, long sent, long received, String mode, int minLatency, int avgLatency, int maxLatency, int nodeCount, int state,Date date) { public ZookeeperRecord(String hostname,int connections, int watches, long sent, long received, String mode, float minLatency, float avgLatency, float maxLatency, int nodeCount, int state,Date date) { this.hostname = hostname; this.connections = connections; this.watches = watches; Loading Loading @@ -149,23 +149,23 @@ public class ZookeeperRecord { this.mode = mode; } public int getMinLatency() { public float getMinLatency() { return minLatency; } public void setMinLatency(int minLatency) { public void setMinLatency(float minLatency) { this.minLatency = minLatency; } public int getAvgLatency() { public float getAvgLatency() { return avgLatency; } public void setAvgLatency(int avgLatency) { public void setAvgLatency(float avgLatency) { this.avgLatency = avgLatency; } public int getMaxLatency() { public float getMaxLatency() { return maxLatency; } Loading Loading
docker/docker-compose.yml +1 −0 Original line number Diff line number Diff line Loading @@ -23,6 +23,7 @@ services: - "2181:2181" environment: ZOO_MY_ID: 1 ZOO_4LW_COMMANDS_WHITELIST: srvr,ruok,wchs,cons db: image: postgres container_name: postgres Loading
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/utils/ZooKeeperState.java +7 −7 Original line number Diff line number Diff line Loading @@ -33,7 +33,7 @@ public class ZooKeeperState { private final String host; private final int port; private int minLatency = -1, avgLatency = -1, maxLatency = -1; private float minLatency = -1, avgLatency = -1, maxLatency = -1; private long received = -1; private long sent = -1; private int outStanding = -1; Loading @@ -60,9 +60,9 @@ public class ZooKeeperState { String line = scannerForStat.nextLine(); if (line.startsWith("Latency min/avg/max:")) { String[] latencys = getStringValueFromLine(line).split("/"); minLatency = Integer.parseInt(latencys[0]); avgLatency = Integer.parseInt(latencys[1]); maxLatency = Integer.parseInt(latencys[2]); minLatency = Float.parseFloat(latencys[0]); avgLatency = Float.parseFloat(latencys[1]); maxLatency = Float.parseFloat(latencys[2]); } else if (line.startsWith("Received:")) { received = Long.parseLong(getStringValueFromLine(line)); } else if (line.startsWith("Sent:")) { Loading Loading @@ -165,15 +165,15 @@ public class ZooKeeperState { return port; } public int getMinLatency() { public float getMinLatency() { return minLatency; } public int getAvgLatency() { public float getAvgLatency() { return avgLatency; } public int getMaxLatency() { public float getMaxLatency() { return maxLatency; } Loading
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/utils/ZookeeperMonitor.java +3 −3 Original line number Diff line number Diff line Loading @@ -88,9 +88,9 @@ public class ZookeeperMonitor extends AbstractZKClient { long sent = state.getSent(); long received = state.getReceived(); String mode = state.getMode(); int minLatency = state.getMinLatency(); int avgLatency = state.getAvgLatency(); int maxLatency = state.getMaxLatency(); float minLatency = state.getMinLatency(); float avgLatency = state.getAvgLatency(); float maxLatency = state.getMaxLatency(); int nodeCount = state.getNodeCount(); int status = ok ? 1 : 0; Date date = new Date(); Loading
dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/ZookeeperRecord.java +9 −9 Original line number Diff line number Diff line Loading @@ -56,17 +56,17 @@ public class ZookeeperRecord { /** * min Latency */ private int minLatency; private float minLatency; /** * avg Latency */ private int avgLatency; private float avgLatency; /** * max Latency */ private int maxLatency; private float maxLatency; /** * node count Loading @@ -85,7 +85,7 @@ public class ZookeeperRecord { private int state; public ZookeeperRecord(String hostname,int connections, int watches, long sent, long received, String mode, int minLatency, int avgLatency, int maxLatency, int nodeCount, int state,Date date) { public ZookeeperRecord(String hostname,int connections, int watches, long sent, long received, String mode, float minLatency, float avgLatency, float maxLatency, int nodeCount, int state,Date date) { this.hostname = hostname; this.connections = connections; this.watches = watches; Loading Loading @@ -149,23 +149,23 @@ public class ZookeeperRecord { this.mode = mode; } public int getMinLatency() { public float getMinLatency() { return minLatency; } public void setMinLatency(int minLatency) { public void setMinLatency(float minLatency) { this.minLatency = minLatency; } public int getAvgLatency() { public float getAvgLatency() { return avgLatency; } public void setAvgLatency(int avgLatency) { public void setAvgLatency(float avgLatency) { this.avgLatency = avgLatency; } public int getMaxLatency() { public float getMaxLatency() { return maxLatency; } Loading