You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yc...@apache.org on 2025/05/26 13:02:56 UTC
(iotdb) branch cp13client created (now 77e342d2197)
This is an automated email from the ASF dual-hosted git repository.
ycycse pushed a change to branch cp13client
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 77e342d2197 [AINode] Return ainodeClient in clientPool
This branch includes the following new commits:
new 77e342d2197 [AINode] Return ainodeClient in clientPool
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(iotdb) 01/01: [AINode] Return ainodeClient in clientPool
Posted by yc...@apache.org.
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 <yc...@gmail.com>
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