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

marklau99 pushed a commit to branch IOTDB-5517
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/IOTDB-5517 by this push:
     new 2bf6074558 fix some bug
2bf6074558 is described below

commit 2bf607455818224615b0938fcacb17be867c9b2d
Author: Liu Xuxin <[email protected]>
AuthorDate: Mon Feb 13 17:57:16 2023 +0800

    fix some bug
---
 .../apache/iotdb/db/service/metrics/io/LinuxDiskMetricsManager.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/service/metrics/io/LinuxDiskMetricsManager.java
 
b/server/src/main/java/org/apache/iotdb/db/service/metrics/io/LinuxDiskMetricsManager.java
index 8c919ec968..a16e8ad213 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/service/metrics/io/LinuxDiskMetricsManager.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/service/metrics/io/LinuxDiskMetricsManager.java
@@ -244,12 +244,12 @@ public class LinuxDiskMetricsManager extends 
AbstractDiskMetricsManager {
 
   @Override
   public long getAttemptReadSizeForProcess() {
-    return 0;
+    return incrementAttemptReadSizeForProcess / 1024L / updateInterval * 1000L;
   }
 
   @Override
   public long getAttemptWriteSizeForProcess() {
-    return 0;
+    return incrementAttemptWriteSizeForProcess / 1024L / updateInterval * 
1000L;
   }
 
   @Override
@@ -298,7 +298,7 @@ public class LinuxDiskMetricsManager extends 
AbstractDiskMetricsManager {
         long readTimeCost = 
Long.parseLong(diskInfo[DISK_READ_TIME_COST_OFFSET]);
         long writeTimeCost = 
Long.parseLong(diskInfo[DISK_WRITE_TIME_COST_OFFSET]);
         long lastMergedReadCount = 
lastMergedReadCountForDisk.getOrDefault(diskId, 0L);
-        long lastMergedWriteCount = 
lastMergedReadCountForDisk.getOrDefault(diskId, 0L);
+        long lastMergedWriteCount = 
lastMergedWriteCountForDisk.getOrDefault(diskId, 0L);
         int lastReadOperationCount = 
lastReadOperationCountForDisk.getOrDefault(diskId, 0);
         int lastWriteOperationCount = 
lastWriteOperationCountForDisk.getOrDefault(diskId, 0);
         long lastSectorReadCount = 
lastReadSectorCountForDisk.getOrDefault(diskId, 0L);

Reply via email to