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

[justinchen]

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

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

commit 7ef7a7e99c0ddd9af397f7101f16efda21211e65
Author: Zhenyu Luo <luoluoyuyu2...@gmail.com>
AuthorDate: Tue Jul 8 14:59:07 2025 +0800

    Pipe: Fix the error of Client object returning to object pool after file 
transfer is completed (#15883) (#15885)
    
    (cherry picked from commit 4cc6085e35cbebb2d1c65006b559c65b7b884901)
---
 .../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 fd80f47c45f..ac639fd2257 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
@@ -409,7 +409,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);