This is an automated email from the ASF dual-hosted git repository.

jt2594838 pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new e7d97e60dd1 Reduce AirGap receiver log noise (#18424) (#18427)
e7d97e60dd1 is described below

commit e7d97e60dd11a7c6f1391353c6edd877d7d23ac8
Author: Caideyipi <[email protected]>
AuthorDate: Mon Aug 10 11:13:18 2026 +0800

    Reduce AirGap receiver log noise (#18424) (#18427)
---
 .../iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiver.java | 6 ------
 1 file changed, 6 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 278c1ccaaef..bb6bbbed8c1 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
@@ -161,10 +161,6 @@ public class IoTDBAirGapReceiver extends WrappedRunnable {
     } else if (status.getCode() == 
TSStatusCode.REDIRECTION_RECOMMEND.getStatusCode()
         || status.getCode()
             == 
TSStatusCode.PIPE_RECEIVER_IDEMPOTENT_CONFLICT_EXCEPTION.getStatusCode()) {
-      LOGGER.info(
-          "Pipe air gap receiver {}: TSStatus {} is encountered at the air gap 
receiver, will ignore.",
-          receiverId,
-          resp.getStatus());
       ok();
     } else if (status.getCode()
         == 
TSStatusCode.PIPE_RECEIVER_TEMPORARY_UNAVAILABLE_EXCEPTION.getStatusCode()) {
@@ -173,8 +169,6 @@ 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