From 336040144b938221ba9b1346feea7fc3a1350dc0 Mon Sep 17 00:00:00 2001
From: Peng Junzhi <201250214@smail.nju.edu.cn>
Date: Mon, 18 May 2026 14:29:31 +0800
Subject: [PATCH] Fix IoTConsensus V2 metric unbinding

---
 .../consensus/pipe/metric/IoTConsensusV2ServerMetrics.java      | 2 +-
 .../db/pipe/consensus/metric/IoTConsensusV2SinkMetrics.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetrics.java b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetrics.java
index 14c1f48621ff9..2c10d434b512a 100644
--- a/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetrics.java
+++ b/iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetrics.java
@@ -174,7 +174,7 @@ public void unbindStageTimer(AbstractMetricService metricService) {
         Tag.NAME.toString(),
         Metric.IOT_CONSENSUS_V2.toString(),
         Tag.TYPE.toString(),
-        "writeStateMachine",
+        "userWriteStateMachine",
         Tag.REGION.toString(),
         impl.getConsensusGroupId());
     metricService.remove(
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/IoTConsensusV2SinkMetrics.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/IoTConsensusV2SinkMetrics.java
index fcec5539bdfe0..4e75102223383 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/IoTConsensusV2SinkMetrics.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/metric/IoTConsensusV2SinkMetrics.java
@@ -239,7 +239,7 @@ private void unbindTimer(AbstractMetricService metricService) {
         Tag.NAME.toString(),
         CONNECTOR,
         Tag.TYPE.toString(),
-        "connectorTsFileTransfer",
+        "connectorEnqueue",
         Tag.REGION.toString(),
         iotConsensusV2AsyncConnector.getConsensusGroupIdStr());
     metricService.remove(