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);