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);