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

Merge pull request #3526 from actiontech/inner/2042

Browse Source 
[inner-2042] adjust statistic_queue_monitor
This commit is contained in:
wenyh
2022-12-07 13:54:02 +08:00
committed by GitHub
parent 6980f60255 6b816e1aa2
commit 1d3a896862
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

@@ -447,14 +447,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;
}
}
}
}