(iotdb) branch master updated: Pipe: Fix the error of Client object returning to object pool after file transfer is completed (#15883)

[justinchen]

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

justinchen 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 4cc6085e35c Pipe: Fix the error of Client object returning to object 
pool after file transfer is completed (#15883)
4cc6085e35c is described below

commit 4cc6085e35cbebb2d1c65006b559c65b7b884901
Author: Zhenyu Luo <luoluoyuyu2...@gmail.com>
AuthorDate: Tue Jul 8 10:03:55 2025 +0800

    Pipe: Fix the error of Client object returning to object pool after file 
transfer is completed (#15883)
---
 .../connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
index 3b7a0f862c9..af10360a036 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java
@@ -436,7 +436,7 @@ public class IoTDBDataRegionAsyncConnector extends 
IoTDBConnector {
               AsyncPipeDataTransferServiceClient client = null;
               try {
                 client = transferTsFileClientManager.borrowClient();
-                pipeTransferTsFileHandler.transfer(clientManager, client);
+                
pipeTransferTsFileHandler.transfer(transferTsFileClientManager, client);
               } catch (final Exception ex) {
                 logOnClientException(client, ex);
                 pipeTransferTsFileHandler.onError(ex);