Skip to content

Commit 7ef7a7e

Browse files
authored
Pipe: Fix the error of Client object returning to object pool after file transfer is completed (#15883) (#15885)
(cherry picked from commit 4cc6085)
1 parent 5852681 commit 7ef7a7e

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBDataRegionAsyncConnector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -409,7 +409,7 @@ private void transfer(final PipeTransferTsFileHandler pipeTransferTsFileHandler)
409409
AsyncPipeDataTransferServiceClient client = null;
410410
try {
411411
client = transferTsFileClientManager.borrowClient();
412-
pipeTransferTsFileHandler.transfer(clientManager, client);
412+
pipeTransferTsFileHandler.transfer(transferTsFileClientManager, client);
413413
} catch (final Exception ex) {
414414
logOnClientException(client, ex);
415415
pipeTransferTsFileHandler.onError(ex);

0 commit comments

Comments
 (0)