(iotdb) branch master updated: Fix ConfigNodeClient thread leak at DataRegion.java (#16427)

[yongzao]

This is an automated email from the ASF dual-hosted git repository.

yongzao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 84ac94d1d0c Fix ConfigNodeClient thread leak at DataRegion.java 
(#16427)
84ac94d1d0c is described below

commit 84ac94d1d0c5c1cfa20891c11726e2036f5c77fc
Author: Yongzao <yong...@apache.org>
AuthorDate: Thu Sep 18 09:49:30 2025 +0800

    Fix ConfigNodeClient thread leak at DataRegion.java (#16427)
---
 .../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())