This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch enhance_remove_confignode in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 253af0b5292f9a08dc50b1af73189f6f9d0536ef Author: OneSizeFitQuorum <[email protected]> AuthorDate: Wed Apr 2 16:56:35 2025 +0800 finish Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../java/org/apache/iotdb/confignode/manager/node/NodeManager.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java index 3d5ef0945c7..cd492cf8457 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeManager.java @@ -69,7 +69,6 @@ import org.apache.iotdb.confignode.manager.UDFManager; import org.apache.iotdb.confignode.manager.consensus.ConsensusManager; import org.apache.iotdb.confignode.manager.load.LoadManager; import org.apache.iotdb.confignode.manager.load.cache.node.ConfigNodeHeartbeatCache; -import org.apache.iotdb.confignode.manager.load.service.StatisticsService; import org.apache.iotdb.confignode.manager.partition.PartitionManager; import org.apache.iotdb.confignode.manager.partition.PartitionMetrics; import org.apache.iotdb.confignode.manager.pipe.coordinator.PipeManager; @@ -814,8 +813,7 @@ public class NodeManager { final long deadline = System.nanoTime() + TimeUnit.MILLISECONDS.toNanos( - (CONF.getHeartbeatIntervalInMs() + StatisticsService.STATISTICS_UPDATE_INTERVAL) - * 3); + CommonDescriptor.getInstance().getConfig().getDnConnectionTimeoutInMS() / 2); while (filterConfigNodeThroughStatus(NodeStatus.Running).size() <= 1) { if (System.nanoTime() > deadline) { return new TSStatus(TSStatusCode.REMOVE_CONFIGNODE_ERROR.getStatusCode())
