This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new e281a308851 Reduce AirGap receiver log noise (#18424)
e281a308851 is described below
commit e281a308851a4313c33f8876eafe8dcc28ba1c93
Author: Caideyipi <[email protected]>
AuthorDate: Fri Aug 7 18:35:25 2026 +0800
Reduce AirGap receiver log noise (#18424)
---
.../main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 ----
.../main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 ----
.../iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiver.java | 5 -----
3 files changed, 13 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
b/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
index 757529f3aa0..d7c54994a6d 100644
---
a/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
+++
b/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
@@ -1295,8 +1295,6 @@ public final class DataNodePipeMessages {
"Pipe air gap receiver {} started. Socket: {}";
public static final String PIPE_AIR_GAP_RECEIVER_TEMPORARY_UNAVAILABLE_RETRY
=
"Pipe air gap receiver {}: Temporary unavailable retry timed out,
returning FAIL to sender.";
- public static final String PIPE_AIR_GAP_RECEIVER_TSSTATUS_IS_ENCOUNTERED =
- "Pipe air gap receiver {}: TSStatus {} is encountered at the air gap
receiver, will ignore.";
public static final String PIPE_DATA_TRANSPORT_ERROR = "Pipe data transport
error, {}";
public static final String PIPE_INSERTING_ROW_CASTING_TYPE_FROM =
"Pipe: Inserting row. Casting type from {} to {}.";
@@ -1337,8 +1335,6 @@ public final class DataNodePipeMessages {
"Start load pipeData with serialize number {} and type {},value={}";
public static final String STORAGE_ENGINE_READONLY = "storage engine
readonly";
public static final String SYNC_START_AT_TO_IS_DONE = "Sync {} start at {}
to {} is done.";
- public static final String
TEMPORARY_UNAVAILABLE_EXCEPTION_ENCOUNTERED_AT_AIR_GAP =
- "Temporary unavailable exception encountered at air gap receiver, will
retry locally.";
public static final String
THE_IOTCONSENSUSV2_REQUEST_VERSION_IS_DIFFERENT_FROM =
"The iotConsensusV2 request version {} is different from the sender
request version {}, "
+ "the receiver will be reset to the sender request version.";
diff --git
a/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
b/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
index 6fd1922c6a6..beed68e1cde 100644
---
a/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
+++
b/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java
@@ -1215,8 +1215,6 @@ public final class DataNodePipeMessages {
"Pipe air gap receiver {} 已启动。Socket：{}";
public static final String PIPE_AIR_GAP_RECEIVER_TEMPORARY_UNAVAILABLE_RETRY
=
"Pipe air gap receiver {}：临时不可用重试超时，向 sender 返回 FAIL。";
- public static final String PIPE_AIR_GAP_RECEIVER_TSSTATUS_IS_ENCOUNTERED =
- "Pipe air gap receiver {}：在 air gap receiver 处遇到 TSStatus {}，将忽略。";
public static final String PIPE_DATA_TRANSPORT_ERROR = "Pipe 数据传输错误，{}";
public static final String PIPE_INSERTING_ROW_CASTING_TYPE_FROM =
"Pipe：写入 row。将类型从 {} 转换为 {}。";
@@ -1256,8 +1254,6 @@ public final class DataNodePipeMessages {
"开始加载 serialize number 为 {}、type 为 {} 的 pipeData，value={}";
public static final String STORAGE_ENGINE_READONLY = "存储引擎只读";
public static final String SYNC_START_AT_TO_IS_DONE = "Sync {} 从 {} 开始到 {}
已完成。";
- public static final String
TEMPORARY_UNAVAILABLE_EXCEPTION_ENCOUNTERED_AT_AIR_GAP =
- "在 air gap receiver 处遇到临时不可用异常，将在本地重试。";
public static final String
THE_IOTCONSENSUSV2_REQUEST_VERSION_IS_DIFFERENT_FROM =
"iotConsensusV2 请求版本 {} 与 sender 请求版本 {} 不同，"
+ "receiver 将被重置为 sender 请求版本。";
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 1b8012d8ab9..c337f1c60ef 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
@@ -155,10 +155,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(
- DataNodePipeMessages.PIPE_AIR_GAP_RECEIVER_TSSTATUS_IS_ENCOUNTERED,
- receiverId,
- resp.getStatus());
ok();
} else if (status.getCode()
==
TSStatusCode.PIPE_RECEIVER_TEMPORARY_UNAVAILABLE_EXCEPTION.getStatusCode()) {
@@ -167,7 +163,6 @@ public class IoTDBAirGapReceiver extends WrappedRunnable {
} catch (final InterruptedException e) {
Thread.currentThread().interrupt();
}
-
LOGGER.info(DataNodePipeMessages.TEMPORARY_UNAVAILABLE_EXCEPTION_ENCOUNTERED_AT_AIR_GAP);
if (System.currentTimeMillis() - startTime
< PipeConfig.getInstance().getPipeAirGapRetryMaxMs()) {
handleReq(req, startTime);
