This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch enhance_remove_confignode_cp in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e763f9a50af137fe64e1081dab30123bff2da696 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 405ad39d4ad..8925375d573 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; @@ -802,8 +801,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())
