This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch tsfile-2-tablet-metrics in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3ec8eabc16dfb517f5017614b926fe53980f26fd Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Mar 26 20:51:17 2025 +0800 Update PipeDataNodeMetrics.java --- .../main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java index 004b1bccf77..3f03ce580fd 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/PipeDataNodeMetrics.java @@ -23,6 +23,7 @@ import org.apache.iotdb.commons.pipe.metric.PipeEventCommitMetrics; import org.apache.iotdb.db.pipe.metric.overview.PipeDataNodeRemainingEventAndTimeMetrics; import org.apache.iotdb.db.pipe.metric.overview.PipeHeartbeatEventMetrics; import org.apache.iotdb.db.pipe.metric.overview.PipeResourceMetrics; +import org.apache.iotdb.db.pipe.metric.overview.PipeTsFileToTabletsMetrics; import org.apache.iotdb.db.pipe.metric.overview.PipeWALInsertNodeCacheMetrics; import org.apache.iotdb.db.pipe.metric.processor.PipeProcessorMetrics; import org.apache.iotdb.db.pipe.metric.receiver.PipeDataNodeReceiverMetrics; @@ -54,6 +55,7 @@ public class PipeDataNodeMetrics implements IMetricSet { PipeSchemaRegionConnectorMetrics.getInstance().bindTo(metricService); PipeDataNodeRemainingEventAndTimeMetrics.getInstance().bindTo(metricService); PipeDataNodeReceiverMetrics.getInstance().bindTo(metricService); + PipeTsFileToTabletsMetrics.getInstance().bindTo(metricService); } @Override @@ -71,6 +73,7 @@ public class PipeDataNodeMetrics implements IMetricSet { PipeSchemaRegionConnectorMetrics.getInstance().unbindFrom(metricService); PipeDataNodeRemainingEventAndTimeMetrics.getInstance().unbindFrom(metricService); PipeDataNodeReceiverMetrics.getInstance().unbindFrom(metricService); + PipeTsFileToTabletsMetrics.getInstance().unbindFrom(metricService); } //////////////////////////// singleton ////////////////////////////
