This is an automated email from the ASF dual-hosted git repository.
chaow 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 6b5ba69 fix monitor bug (#3459)
6b5ba69 is described below
commit 6b5ba6901e0dc8169fbe865005cfba138bff4e48
Author: yanhong wang <[email protected]>
AuthorDate: Fri Jul 2 09:49:01 2021 +0800
fix monitor bug (#3459)
---
.../src/main/java/org/apache/iotdb/db/cost/statistic/Measurement.java | 4 +---
server/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java | 4 +++-
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/server/src/main/java/org/apache/iotdb/db/cost/statistic/Measurement.java
b/server/src/main/java/org/apache/iotdb/db/cost/statistic/Measurement.java
index d48d227..c73ccb2 100644
--- a/server/src/main/java/org/apache/iotdb/db/cost/statistic/Measurement.java
+++ b/server/src/main/java/org/apache/iotdb/db/cost/statistic/Measurement.java
@@ -143,9 +143,7 @@ public class Measurement implements MeasurementMBean,
IService {
if (consumeFuture != null && !consumeFuture.isCancelled()) {
logger.info("The consuming task in measurement stat module is already
running...");
} else {
- consumeFuture =
- service.scheduleWithFixedDelay(
- new Measurement.DisplayRunnable(), 20, displayIntervalInMs,
TimeUnit.MILLISECONDS);
+ consumeFuture = service.schedule(new QueueConsumerThread(), 0,
TimeUnit.MILLISECONDS);
}
} catch (Exception e) {
logger.error("Find error when start performance statistic thread, ", e);
diff --git a/server/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java
b/server/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java
index d78d62a..a948048 100644
--- a/server/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/monitor/StatMonitor.java
@@ -198,7 +198,9 @@ public class StatMonitor implements StatMonitorMBean,
IService {
public void updateStatGlobalValue(int successPointsNum) {
// 0 -> TOTAL_POINTS, 1 -> REQ_SUCCESS
globalSeriesValue.set(0, globalSeriesValue.get(0) + successPointsNum);
- globalSeriesValue.set(1, globalSeriesValue.get(1) + 1);
+ if (successPointsNum != 0) {
+ globalSeriesValue.set(1, globalSeriesValue.get(1) + 1);
+ }
}
public void updateFailedStatValue() {
