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

typo

Browse Source
This commit is contained in:
baofengqi
2025-06-18 14:17:55 +08:00
committed by Rico
parent c2b61e52f0
commit 10ae1ae1a2
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/actiontech/dble/backend/heartbeat/MySQLDelayDetector.java
+1 -1
View File
@@ -45,9 +45,9 @@ public class MySQLDelayDetector extends MySQLDetector {
long logic = dbGroup.getLogicTimestamp().get();
long result = logic - delay;
if (result >= 0) {
int delayPeriodMillis = dbGroup.getDbGroupConfig().getDelayPeriodMillis();
long delayVal = 0;
if (result > 0) {
int delayPeriodMillis = dbGroup.getDbGroupConfig().getDelayPeriodMillis();
delayVal = (result * delayPeriodMillis) + (delayPeriodMillis / 2);
}
if (delayThreshold > 0 && delayVal > delayThreshold) {