From e7802d5b7ca0a5793cf2ab654f5601725794caa5 Mon Sep 17 00:00:00 2001 From: luoluoyuyu Date: Thu, 21 May 2026 11:04:34 +0800 Subject: [PATCH] Update TsFile snapshot version and soften pipe metrics deregistration logging --- .../en/org/apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 ++-- .../zh/org/apache/iotdb/db/i18n/DataNodePipeMessages.java | 4 ++-- .../db/pipe/metric/overview/PipeTsFileToTabletsMetrics.java | 2 +- pom.xml | 2 +- 4 files changed, 6 insertions(+), 6 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 2edd14936a985..43ccba45cae19 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 @@ -1291,8 +1291,8 @@ public final class DataNodePipeMessages { public static final String FAILED_TO_DEREGISTER_PIPE_SCHEMA_REGION_SOURCE = "Failed to deregister pipe schema region source metrics, IoTDBSchemaRegionSource({}) " + "does not exist"; - public static final String FAILED_TO_DEREGISTER_PIPE_TSFILE_TO_TABLETS = - "Failed to deregister pipe tsfile to tablets metrics, pipeID({}) does not exist"; + public static final String SKIP_DEREGISTER_PIPE_TSFILE_TO_TABLETS = + "Skip deregistering pipe tsfile to tablets metrics because pipeID({}) is not registered"; public static final String FAILED_TO_DEREGISTER_SCHEMA_REGION_LISTENER_METRICS = "Failed to deregister schema region listener metrics, SchemaRegionListeningQueue({}) " + "does not exist"; 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 ebd58bc0c62d0..adb27e509014f 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 @@ -1243,8 +1243,8 @@ public final class DataNodePipeMessages { "注销 pipe schema region connector metrics, PipeConnectorSubtask({}) does not exist 失败"; public static final String FAILED_TO_DEREGISTER_PIPE_SCHEMA_REGION_SOURCE = "注销 pipe schema region source metrics, IoTDBSchemaRegionSource({}) does not exist 失败"; - public static final String FAILED_TO_DEREGISTER_PIPE_TSFILE_TO_TABLETS = - "注销 pipe tsfile to tablets metrics, pipeID({}) does not exist 失败"; + public static final String SKIP_DEREGISTER_PIPE_TSFILE_TO_TABLETS = + "跳过注销 pipe tsfile to tablets metrics,因为 pipeID({}) 未注册"; public static final String FAILED_TO_DEREGISTER_SCHEMA_REGION_LISTENER_METRICS = "注销 schema region listener metrics, SchemaRegionListeningQueue({}) does not exist 失败"; public static final String FAILED_TO_MARK_PIPE_DATA_REGION_EXTRACTOR = diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeTsFileToTabletsMetrics.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeTsFileToTabletsMetrics.java index fa67c6663d143..1a958c7d3a608 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeTsFileToTabletsMetrics.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeTsFileToTabletsMetrics.java @@ -157,7 +157,7 @@ public void register(final IoTDBDataRegionSource extractor) { public void deregister(final String pipeID) { if (!pipe.contains(pipeID)) { - LOGGER.warn(DataNodePipeMessages.FAILED_TO_DEREGISTER_PIPE_TSFILE_TO_TABLETS, pipeID); + LOGGER.info(DataNodePipeMessages.SKIP_DEREGISTER_PIPE_TSFILE_TO_TABLETS, pipeID); return; } try { diff --git a/pom.xml b/pom.xml index b2591ac6730df..a4a064b88843b 100644 --- a/pom.xml +++ b/pom.xml @@ -164,7 +164,7 @@ 0.14.1 1.9 1.5.6-3 - 2.3.1-260519-SNAPSHOT + 2.3.1-260520-SNAPSHOT en