(iotdb) branch dev/1.3 updated: [To rel/1.3][AINode] Return ainodeClient in clientPool

[jackietien]

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

jackietien pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new d20c59d72b2 [To rel/1.3][AINode] Return ainodeClient in clientPool
d20c59d72b2 is described below

commit d20c59d72b20e90e7aa596f90139255c5f1d7d90
Author: YangCaiyin <ycy...@gmail.com>
AuthorDate: Tue May 27 09:01:07 2025 +0800

    [To rel/1.3][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 cc93a8f32d5..7c1ec79b179 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
@@ -189,7 +189,7 @@ public class AINodeClient implements AutoCloseable, 
ThriftClient {
 
   @Override
   public void close() throws Exception {
-    Optional.ofNullable(transport).ifPresent(TTransport::close);
+    clientManager.returnClient(endPoint, this);
   }
 
   @Override
@@ -218,7 +218,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