Skip to content

Commit 4cc6085

Browse files
authored
Pipe: Fix the error of Client object returning to object pool after file transfer is completed (#15883)
1 parent c5009f3 commit 4cc6085

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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
@@ -436,7 +436,7 @@ private void transfer(final PipeTransferTsFileHandler pipeTransferTsFileHandler)
436436
AsyncPipeDataTransferServiceClient client = null;
437437
try {
438438
client = transferTsFileClientManager.borrowClient();
439-
pipeTransferTsFileHandler.transfer(clientManager, client);
439+
pipeTransferTsFileHandler.transfer(transferTsFileClientManager, client);
440440
} catch (final Exception ex) {
441441
logOnClientException(client, ex);
442442
pipeTransferTsFileHandler.onError(ex);

0 commit comments

Comments
 (0)