You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2024/01/10 07:58:42 UTC
(iotdb) 01/02: Fix more metric error
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch fix_metric_2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2b90abb78599db560bc06d0bb167af94e9003177
Author: HTHou <hh...@outlook.com>
AuthorDate: Wed Jan 10 10:58:30 2024 +0800
Fix more metric error
---
.../org/apache/iotdb/db/service/metrics/WritingMetrics.java | 10 +++++-----
.../apache/iotdb/db/storageengine/dataregion/DataRegion.java | 8 ++++----
2 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/WritingMetrics.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/WritingMetrics.java
index b77010b1641..505ecd2d529 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/WritingMetrics.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/WritingMetrics.java
@@ -782,7 +782,7 @@ public class WritingMetrics implements IMetricSet {
.count(
number,
Metric.TIMED_FLUSH_MEMTABLE_COUNT.toString(),
- MetricLevel.CORE,
+ MetricLevel.IMPORTANT,
Tag.REGION.toString(),
dataRegionId);
}
@@ -792,7 +792,7 @@ public class WritingMetrics implements IMetricSet {
.count(
number,
Metric.WAL_FLUSH_MEMTABLE_COUNT.toString(),
- MetricLevel.CORE,
+ MetricLevel.IMPORTANT,
Tag.REGION.toString(),
dataRegionId);
}
@@ -802,7 +802,7 @@ public class WritingMetrics implements IMetricSet {
.count(
number,
Metric.SERIES_FULL_FLUSH_MEMTABLE.toString(),
- MetricLevel.CORE,
+ MetricLevel.IMPORTANT,
Tag.REGION.toString(),
dataRegionId);
}
@@ -812,14 +812,14 @@ public class WritingMetrics implements IMetricSet {
.count(
number,
Metric.ACTIVE_MEMTABLE_COUNT.toString(),
- MetricLevel.CORE,
+ MetricLevel.IMPORTANT,
Tag.REGION.toString(),
dataRegionId);
}
public void recordActiveTimePartitionCount(int number) {
MetricService.getInstance()
- .count(number, Metric.ACTIVE_TIME_PARTITION_COUNT.toString(), MetricLevel.CORE);
+ .count(number, Metric.ACTIVE_TIME_PARTITION_COUNT.toString(), MetricLevel.IMPORTANT);
}
// endregion
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index 9e6b22bad00..0a5cfd63960 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -1358,12 +1358,12 @@ public class DataRegion implements IDataRegionForQuery {
.updateAfterOpeningTsFileProcessor(
new DataRegionId(Integer.valueOf(dataRegionId)), timeRangeId);
res = newTsFileProcessor(sequence, timeRangeId);
- tsFileProcessorTreeMap.put(timeRangeId, res);
- tsFileManager.add(res.getTsFileResource(), sequence);
- if (!workSequenceTsFileProcessors.containsKey(timeRangeId)
- && !workSequenceTsFileProcessors.containsKey(timeRangeId)) {
+ if (workSequenceTsFileProcessors.get(timeRangeId) != null
+ && workUnsequenceTsFileProcessors.get(timeRangeId) != null) {
WritingMetrics.getInstance().recordActiveTimePartitionCount(1);
}
+ tsFileProcessorTreeMap.put(timeRangeId, res);
+ tsFileManager.add(res.getTsFileResource(), sequence);
}
return res;