This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch fix_file_double_file_count
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 571451dce49dc9fcd2cca2d824849ab866d46e63
Author: HTHou <[email protected]>
AuthorDate: Tue Dec 5 17:00:31 2023 +0800

    Fix file counted twice in TsFileMetrics
---
 .../org/apache/iotdb/db/service/metrics/file/TsFileMetrics.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/TsFileMetrics.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/TsFileMetrics.java
index f7284c8e85b..2bf47d750ab 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/TsFileMetrics.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/metrics/file/TsFileMetrics.java
@@ -366,7 +366,7 @@ public class TsFileMetrics implements IMetricSet {
             (seq ? SEQUENCE : UNSEQUENCE),
             entry.getKey(),
             innerEntry.getKey(),
-            innerEntry.getValue().getLeft());
+            0);
       }
     }
     for (Map.Entry<String, Map<String, Pair<Long, Gauge>>> entry :
@@ -377,7 +377,7 @@ public class TsFileMetrics implements IMetricSet {
             (seq ? SEQUENCE : UNSEQUENCE),
             entry.getKey(),
             innerEntry.getKey(),
-            innerEntry.getValue().getLeft());
+            0);
       }
     }
     for (Map.Entry<Integer, Pair<Integer, Gauge>> entry :
@@ -386,7 +386,7 @@ public class TsFileMetrics implements IMetricSet {
           seq ? seqLevelTsFileCountMap : unseqLevelTsFileCountMap,
           seq ? SEQUENCE : UNSEQUENCE,
           entry.getKey(),
-          entry.getValue().getLeft());
+          0);
     }
     for (Map.Entry<Integer, Pair<Long, Gauge>> entry :
         (seq ? seqLevelTsFileSizeMap : unseqLevelTsFileSizeMap).entrySet()) {
@@ -394,7 +394,7 @@ public class TsFileMetrics implements IMetricSet {
           seq ? seqLevelTsFileSizeMap : unseqLevelTsFileSizeMap,
           seq ? SEQUENCE : UNSEQUENCE,
           entry.getKey(),
-          entry.getValue().getLeft());
+          0);
     }
   }
 

Reply via email to