This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 05a602c940a Fix statistics error when loading snapshot
05a602c940a is described below
commit 05a602c940a961e6766ada794b959f01a7477564
Author: Chen YZ <[email protected]>
AuthorDate: Fri Apr 26 17:48:50 2024 +0800
Fix statistics error when loading snapshot
---
.../db/schemaengine/schemaregion/impl/SchemaRegionMemoryImpl.java | 6 +++++-
.../db/schemaengine/schemaregion/impl/SchemaRegionPBTreeImpl.java | 6 +++++-
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/impl/SchemaRegionMemoryImpl.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/impl/SchemaRegionMemoryImpl.java
index 46d264fb020..789908aa206 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/impl/SchemaRegionMemoryImpl.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/impl/SchemaRegionMemoryImpl.java
@@ -469,7 +469,11 @@ public class SchemaRegionMemoryImpl implements
ISchemaRegion {
regionStatistics,
metric,
measurementMNode -> {
- regionStatistics.addMeasurement(1L);
+ if (measurementMNode.isLogicalView()) {
+ regionStatistics.addView(1L);
+ } else {
+ regionStatistics.addMeasurement(1L);
+ }
if (measurementMNode.getOffset() == -1) {
return;
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/impl/SchemaRegionPBTreeImpl.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/impl/SchemaRegionPBTreeImpl.java
index 47618defb6a..6c12d31690c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/impl/SchemaRegionPBTreeImpl.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/impl/SchemaRegionPBTreeImpl.java
@@ -226,7 +226,11 @@ public class SchemaRegionPBTreeImpl implements
ISchemaRegion {
private Consumer<IMeasurementMNode<ICachedMNode>> measurementInitProcess() {
return measurementMNode -> {
- regionStatistics.addMeasurement(1L);
+ if (measurementMNode.isLogicalView()) {
+ regionStatistics.addView(1L);
+ } else {
+ regionStatistics.addMeasurement(1L);
+ }
if (measurementMNode.getOffset() == -1) {
return;
}