This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch check-shit in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f0e89bd6ff0a6253253b3e4da009b2e2b106a0eb Author: Steve Yurong Su <[email protected]> AuthorDate: Thu Jul 10 16:00:49 2025 +0800 add shit --- .../async/handler/PipeTransferTsFileHandler.java | 18 +++++++++++++++++- 1 file changed, 17 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/PipeTransferTsFileHandler.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/PipeTransferTsFileHandler.java index d43a9799116..348b5df6b29 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/PipeTransferTsFileHandler.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/PipeTransferTsFileHandler.java @@ -204,6 +204,11 @@ public class PipeTransferTsFileHandler extends PipeTransferTrackableHandler { client.getEndPoint(), (long) (req.getBody().length * weight))); + try { + Thread.sleep(20000); + } catch (InterruptedException e) { + } + if (!tryTransfer(client, req)) { return; } @@ -222,7 +227,10 @@ public class PipeTransferTsFileHandler extends PipeTransferTrackableHandler { : PipeTransferTsFilePieceReq.toTPipeTransferReq( currentFile.getName(), position, payload); final TPipeTransferReq req = connector.compressIfNeeded(uncompressedReq); - + try { + Thread.sleep(20000); + } catch (InterruptedException e) { + } pipeName2WeightMap.forEach( (pipePair, weight) -> connector.rateLimitIfNeeded( @@ -240,6 +248,10 @@ public class PipeTransferTsFileHandler extends PipeTransferTrackableHandler { @Override public void onComplete(final TPipeTransferResp response) { + try { + Thread.sleep(20000); + } catch (InterruptedException e) { + } try { super.onComplete(response); } finally { @@ -349,6 +361,10 @@ public class PipeTransferTsFileHandler extends PipeTransferTrackableHandler { @Override public void onError(final Exception exception) { + try { + Thread.sleep(20000); + } catch (InterruptedException e) { + } try { super.onError(exception); } finally {
