This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch air-gap-local in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit acdfb33f2e234164bb83f9f6f056e96dab08f7fa Author: Caideyipi <[email protected]> AuthorDate: Mon Feb 9 15:55:51 2026 +0800 Update IoTDBAirGapReceiver.java --- .../iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiver.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiver.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiver.java index 0a10db6f433..e076d54b913 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiver.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiver.java @@ -179,7 +179,7 @@ public class IoTDBAirGapReceiver extends WrappedRunnable { } } - private void handleReq(final AirGapPseudoTPipeTransferRequest req) throws IOException { + private void handleReq(final AirGapPseudoTPipeTransferRequest req, final long startTime) throws IOException { final TPipeTransferResp resp = agent.receive(req); final TSStatus status = resp.getStatus(); @@ -200,7 +200,9 @@ public class IoTDBAirGapReceiver extends WrappedRunnable { } catch (final InterruptedException e) { Thread.currentThread().interrupt(); } - handleReq(req); + if (System.currentTimeMillis() - startTime < PipeConfig.getInstance().getPipeAirGapRetryMaxMs()) { + handleReq(req, startTime); + } } else { LOGGER.warn( "Pipe air gap receiver {}: Handle data failed, status: {}, req: {}",
