diff --git a/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java b/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java index 591980548e2c7..80aa854e66cc1 100644 --- a/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java @@ -341,7 +341,6 @@ public void testClosedDataNodeGetConnections() throws Exception { TimeUnit.SECONDS.sleep(1); } } - TimeUnit.SECONDS.sleep(5); } @Test diff --git a/integration-test/src/test/java/org/apache/iotdb/session/it/pool/SessionPoolIT.java b/integration-test/src/test/java/org/apache/iotdb/session/it/pool/SessionPoolIT.java index f42d4237ea9d3..648a6918331cd 100644 --- a/integration-test/src/test/java/org/apache/iotdb/session/it/pool/SessionPoolIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/session/it/pool/SessionPoolIT.java @@ -268,7 +268,6 @@ public void tryIfTheServerIsRestart() throws InterruptedException { .ensureNodeStatus( Collections.singletonList(node), Collections.singletonList(NodeStatus.Running)); pool = EnvFactory.getEnv().getSessionPool(3); - TimeUnit.SECONDS.sleep(5); correctQuery(pool, DEFAULT_QUERY_TIMEOUT); pool.close(); return; @@ -354,7 +353,6 @@ public void restart() throws InterruptedException { EnvFactory.getEnv() .ensureNodeStatus( Collections.singletonList(node), Collections.singletonList(NodeStatus.Running)); - TimeUnit.SECONDS.sleep(5); write10Data(pool, true); pool.close(); } diff --git a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java index c9c2b393cdeb8..6811c8143d256 100644 --- a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java +++ b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java @@ -50,6 +50,17 @@ public DiskMetrics(String processName) { @Override public void bindTo(AbstractMetricService metricService) { + String os = System.getProperty("os.name").toLowerCase(); + if (os.startsWith("windows")) { + Thread thread = new Thread(() -> bindTask(metricService), "Windows-Disk-Metric-Binder"); + thread.setDaemon(true); + thread.start(); + return; + } + bindTask(metricService); + } + + private void bindTask(AbstractMetricService metricService) { // metrics for disks Set diskIDs = diskMetricsManager.getDiskIds(); for (String diskID : diskIDs) { diff --git a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/WindowsDiskMetricsManager.java b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/WindowsDiskMetricsManager.java index b83e0c5aa1702..a82b048f6db38 100644 --- a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/WindowsDiskMetricsManager.java +++ b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/WindowsDiskMetricsManager.java @@ -106,7 +106,6 @@ public class WindowsDiskMetricsManager implements IDiskMetricsManager { public WindowsDiskMetricsManager() { processId = String.valueOf(MetricConfigDescriptor.getInstance().getMetricConfig().getPid()); - collectDiskId(); } @Override @@ -235,15 +234,6 @@ public Set getDiskIds() { return diskIdSet; } - private void collectDiskId() { - Map diskInfoMap = queryDiskInfo(); - if (diskInfoMap.isEmpty()) { - return; - } - diskIdSet.clear(); - diskIdSet.addAll(diskInfoMap.keySet()); - } - private Map toKbMap(Map source) { Map result = new HashMap<>(source.size()); for (Map.Entry entry : source.entrySet()) { diff --git a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java index 3561fd7997cfb..49c98702ad769 100644 --- a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java +++ b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/NetMetrics.java @@ -41,6 +41,17 @@ public NetMetrics(String processName) { @Override public void bindTo(AbstractMetricService metricService) { + String os = System.getProperty("os.name").toLowerCase(); + if (os.startsWith("windows")) { + Thread thread = new Thread(() -> bindTask(metricService), "Windows-Net-Metric-Binder"); + thread.setDaemon(true); + thread.start(); + return; + } + bindTask(metricService); + } + + private void bindTask(AbstractMetricService metricService) { // metrics for net Set ifaceSet = netMetricManager.getIfaceSet(); for (String iface : ifaceSet) { diff --git a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/WindowsNetMetricManager.java b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/WindowsNetMetricManager.java index 7fb82ffaa0dc2..62991048cab4a 100644 --- a/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/WindowsNetMetricManager.java +++ b/iotdb-core/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/net/WindowsNetMetricManager.java @@ -56,9 +56,7 @@ public class WindowsNetMetricManager implements INetMetricManager { private int connectionNum = 0; - public WindowsNetMetricManager() { - checkUpdate(); - } + public WindowsNetMetricManager() {} @Override public Set getIfaceSet() {