We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 32add57 commit 0aa01f6Copy full SHA for 0aa01f6
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClient.java
@@ -219,7 +219,7 @@ public TSStatus createTrainingTask(TTrainingReq req) throws TException {
219
220
@Override
221
public void close() throws Exception {
222
- Optional.ofNullable(transport).ifPresent(TTransport::close);
+ clientManager.returnClient(endPoint, this);
223
}
224
225
@@ -248,7 +248,7 @@ public Factory(
248
249
public void destroyObject(TEndPoint tEndPoint, PooledObject<AINodeClient> pooledObject)
250
throws Exception {
251
- pooledObject.getObject().close();
+ pooledObject.getObject().invalidate();
252
253
254
0 commit comments