This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch fix-cli-thread-leak in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1362a84c02e9e3b70d3bbd191db5581b4ed1dd27 Author: Yongzao <[email protected]> AuthorDate: Wed Sep 17 10:36:05 2025 +0800 Update DataRegion.java --- .../apache/iotdb/db/storageengine/dataregion/DataRegion.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java index 285f3afd3f2..0a923991ed8 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java @@ -1434,11 +1434,11 @@ public class DataRegion implements IDataRegionForQuery { if (node.isGeneratedByRemoteConsensusLeader()) { // If current node is follower, after request config node and get the answer that // table is exist or not, then tell leader node when table is not exist. - try { - TDescTableResp resp = - ConfigNodeClientManager.getInstance() - .borrowClient(ConfigNodeInfo.CONFIG_REGION_ID) - .describeTable(getDatabaseName(), tableName, false); + TDescTableResp resp; + try (ConfigNodeClient client = + ConfigNodeClientManager.getInstance() + .borrowClient(ConfigNodeInfo.CONFIG_REGION_ID)) { + resp = client.describeTable(getDatabaseName(), tableName, false); tsTable = (resp != null) && (resp.tableInfo != null) ? TsTableInternalRPCUtil.deserializeSingleTsTable(resp.getTableInfo())
