This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch fix_writing_metric_3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4603c2ac12946e05744a7e9bd25942e8bee370f1 Author: HTHou <[email protected]> AuthorDate: Thu Jan 18 12:02:56 2024 +0800 fix ActiveMemTableCount update error --- .../iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java | 2 ++ .../db/storageengine/dataregion/wal/recover/file/TsFilePlanRedoer.java | 2 ++ 2 files changed, 4 insertions(+) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java index 837b4dd3491..4cd143ad5fb 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java @@ -350,6 +350,8 @@ public class TsFileProcessor { long startTime = System.nanoTime(); createNewWorkingMemTable(); PERFORMANCE_OVERVIEW_METRICS.recordCreateMemtableBlockCost(System.nanoTime() - startTime); + WritingMetrics.getInstance() + .recordActiveMemTableCount(dataRegionInfo.getDataRegion().getDataRegionId(), 1); } long[] memIncrements = null; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/recover/file/TsFilePlanRedoer.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/recover/file/TsFilePlanRedoer.java index 7bf3e136701..1df025cd371 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/recover/file/TsFilePlanRedoer.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/recover/file/TsFilePlanRedoer.java @@ -25,6 +25,7 @@ import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.DeleteDataNo import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.InsertNode; import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.InsertRowNode; import org.apache.iotdb.db.queryengine.plan.planner.plan.node.write.InsertTabletNode; +import org.apache.iotdb.db.service.metrics.WritingMetrics; import org.apache.iotdb.db.storageengine.dataregion.memtable.DeviceIDFactory; import org.apache.iotdb.db.storageengine.dataregion.memtable.IMemTable; import org.apache.iotdb.db.storageengine.dataregion.memtable.PrimitiveMemTable; @@ -52,6 +53,7 @@ public class TsFilePlanRedoer { this.sequence = sequence; this.recoveryMemTable = new PrimitiveMemTable(tsFileResource.getDatabaseName(), tsFileResource.getDataRegionId()); + WritingMetrics.getInstance().recordActiveMemTableCount(tsFileResource.getDataRegionId(), 1); } void redoDelete(DeleteDataNode deleteDataNode) throws IOException {
