mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-02 02:40:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

[inner-2042] adjust statistic_queue_monitor

Browse Source 
(cherry picked from commit d32fb40a32)
This commit is contained in:
wenyh1
2022-12-07 13:19:13 +08:00
parent 92802c3268
commit 7345ef9604
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/actiontech/dble/services/manager/response/StatisticCf.java
View File

@@ -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;
}
}
}
}