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


The following commit(s) were added to refs/heads/air-gap-local by this push:
     new 11b5411bbd3 logger
11b5411bbd3 is described below

commit 11b5411bbd38eadc978dde1afa875f2857a3cf2c
Author: Caideyipi <[email protected]>
AuthorDate: Mon Feb 9 17:16:11 2026 +0800

    logger
---
 .../iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiver.java     | 2 ++
 1 file changed, 2 insertions(+)

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 5d2e7013b34..0ff1834e8cd 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
@@ -173,6 +173,8 @@ public class IoTDBAirGapReceiver extends WrappedRunnable {
       } catch (final InterruptedException e) {
         Thread.currentThread().interrupt();
       }
+      LOGGER.info(
+          "Temporary unavailable exception encountered at air gap receiver, 
will retry locally.");
       if (System.currentTimeMillis() - startTime
           < PipeConfig.getInstance().getPipeAirGapRetryMaxMs()) {
         handleReq(req, startTime);

Reply via email to