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

[bug]fix slave delay calculation method

Browse Source
This commit is contained in:
baofengqi
2025-06-18 14:02:50 +08:00
committed by Rico
parent 1970786ccc
commit 34dc2c3d60
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/actiontech/dble/backend/heartbeat/MySQLDelayDetector.java
View File

@@ -45,7 +45,7 @@ public class MySQLDelayDetector extends MySQLDetector {
long logic = dbGroup.getLogicTimestamp().get();
long result = logic - delay;
if (result >= 0) {
long delayVal = result * (dbGroup.getDbGroupConfig().getDelayPeriodMillis() / 2);
long delayVal = result * dbGroup.getDbGroupConfig().getDelayPeriodMillis();
if (delayThreshold > 0 && delayVal > delayThreshold) {
MySQLHeartbeat.LOGGER.warn("found MySQL master/slave Replication delay !!! " + heartbeat.getSource().getConfig() + ", binlog sync time delay: " + delayVal + "ms");
}