From 3ab607ee91e29d55a2efcaafb5014e6db7a47abc Mon Sep 17 00:00:00 2001 From: Cursor Agent Date: Mon, 19 Jan 2026 06:28:27 +0000 Subject: [PATCH] Gate delay rebase on init timestamp Co-authored-by: 859235917 <859235917@qq.com> --- .../actiontech/dble/backend/heartbeat/MySQLDelayDetector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/actiontech/dble/backend/heartbeat/MySQLDelayDetector.java b/src/main/java/com/actiontech/dble/backend/heartbeat/MySQLDelayDetector.java index 501df8390..a9f863636 100644 --- a/src/main/java/com/actiontech/dble/backend/heartbeat/MySQLDelayDetector.java +++ b/src/main/java/com/actiontech/dble/backend/heartbeat/MySQLDelayDetector.java @@ -56,7 +56,7 @@ public class MySQLDelayDetector extends MySQLDetector { heartbeat.setSlaveBehindMaster((int) delayVal); heartbeat.setDbSynStatus(MySQLHeartbeat.DB_SYN_NORMAL); } else { - if (heartbeat.getStatus() != MySQLHeartbeat.OK_STATUS) { + if (logic == 0) { long updatedLogic = dbGroup.getLogicTimestamp().updateAndGet(current -> Math.max(current, delay)); LOGGER.warn("delay detection rebased logic_timestamp to {} for dbGroup {}", updatedLogic, dbGroup.getGroupName()); heartbeat.setSlaveBehindMaster(0);