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

[bug]fix slave delay calculation method

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

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

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