You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2026/08/10 03:13:25 UTC
(iotdb) branch dev/1.3 updated: Reduce AirGap receiver log noise (#18424) (#18427)
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 <87...@users.noreply.github.com>
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);