This is an automated email from the ASF dual-hosted git repository. tanxinyu pushed a commit to branch fix_iotv2_metric_npe in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3962033477f83f92a184e24baaa3504581ff2228 Author: OneSizeFitQuorum <[email protected]> AuthorDate: Tue Oct 29 18:25:04 2024 +0800 fix metric init order Signed-off-by: OneSizeFitQuorum <[email protected]> --- .../db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java index 50fa549b623..54a1d1b9592 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java @@ -116,7 +116,6 @@ public class PipeConsensusReceiver { this.consensusGroupId = consensusGroupId; this.pipeConsensusReceiverMetrics = new PipeConsensusReceiverMetrics(this); this.consensusPipeName = consensusPipeName; - MetricService.getInstance().addMetricSet(pipeConsensusReceiverMetrics); // Each pipeConsensusReceiver has its own base directories. for example, a default dir path is // data/datanode/system/pipe/consensus/receiver/__consensus.{consensusGroupId}_{leaderDataNodeId}_{followerDataNodeId} @@ -145,6 +144,7 @@ public class PipeConsensusReceiver { } this.requestExecutor = new RequestExecutor(pipeConsensusReceiverMetrics, pipeConsensusTsFileWriterPool); + MetricService.getInstance().addMetricSet(pipeConsensusReceiverMetrics); } /**
