This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch rc/1.3.5 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 43334b761c29c4ea3a730851a160363d64c6eb64 Author: Zhenyu Luo <[email protected]> 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);
