You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2024/10/29 10:26:08 UTC
(iotdb) 01/01: fix metric init order
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 <ta...@apache.org>
AuthorDate: Tue Oct 29 18:25:04 2024 +0800
fix metric init order
Signed-off-by: OneSizeFitQuorum <ta...@apache.org>
---
.../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);
}
/**