This is an automated email from the ASF dual-hosted git repository. ycycse pushed a commit to branch cp13client in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 77e342d2197e53a7f7c05b84e28431c358fd9d34 Author: YangCaiyin <[email protected]> AuthorDate: Fri May 23 13:57:23 2025 +0800 [AINode] Return ainodeClient in clientPool (cherry picked from commit 0aa01f6069b0aa6691be1566c5b580b1a69dc1ca) --- .../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
