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 4feb292d301 Fix IoTConsensus V2 metric unbinding (#17704)
4feb292d301 is described below

commit 4feb292d30170679660042008d202676258b0f50
Author: Peng Junzhi <[email protected]>
AuthorDate: Mon May 25 15:31:31 2026 +0800

    Fix IoTConsensus V2 metric unbinding (#17704)
---
 .../apache/iotdb/consensus/pipe/metric/IoTConsensusV2ServerMetrics.java | 2 +-
 .../iotdb/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 14c1f48621f..2c10d434b51 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 class IoTConsensusV2ServerMetrics implements 
IMetricSet {
         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 fcec5539bdf..4e751022233 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 @@ public class IoTConsensusV2SinkMetrics implements 
IMetricSet {
         Tag.NAME.toString(),
         CONNECTOR,
         Tag.TYPE.toString(),
-        "connectorTsFileTransfer",
+        "connectorEnqueue",
         Tag.REGION.toString(),
         iotConsensusV2AsyncConnector.getConsensusGroupIdStr());
     metricService.remove(

Reply via email to