diff --git a/src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java b/src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java index 9102943b6..88310f396 100644 --- a/src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java +++ b/src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java @@ -441,14 +441,14 @@ public class StatisticCf { @Override public void run() { - if (count > observe) { - StatisticManager.getInstance().cancelMonitoring(); - return; - } StatisticManager.getInstance(). getUsageData().add(new UsageDataBlock(DateUtil.parseStr(System.currentTimeMillis(), DateUtil.DEFAULT_DATE_PATTERN), DF.format(1 - (StatisticManager.getInstance().getDisruptorRemaining() / queueSize)))); count += interval; + if (count > observe) { + StatisticManager.getInstance().cancelMonitoring(); + return; + } } } }