(iotdb) branch master updated: [AINode] Return ainodeClient in clientPool

[jackietien]

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

jackietien 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 0aa01f6069b [AINode] Return ainodeClient in clientPool
0aa01f6069b is described below

commit 0aa01f6069b0aa6691be1566c5b580b1a69dc1ca
Author: YangCaiyin <ycy...@gmail.com>
AuthorDate: Fri May 23 13:57:23 2025 +0800

    [AINode] Return ainodeClient in clientPool
---
 .../java/org/apache/iotdb/commons/client/ainode/AINodeClient.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClient.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClient.java
index 5532d283bcb..ae7a521a19a 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClient.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClient.java
@@ -219,7 +219,7 @@ public class AINodeClient implements AutoCloseable, 
ThriftClient {
 
   @Override
   public void close() throws Exception {
-    Optional.ofNullable(transport).ifPresent(TTransport::close);
+    clientManager.returnClient(endPoint, this);
   }
 
   @Override
@@ -248,7 +248,7 @@ public class AINodeClient implements AutoCloseable, 
ThriftClient {
     @Override
     public void destroyObject(TEndPoint tEndPoint, PooledObject<AINodeClient> 
pooledObject)
         throws Exception {
-      pooledObject.getObject().close();
+      pooledObject.getObject().invalidate();
     }
 
     @Override