From c2a3acb40ccf7e836140eb548a3490eb68e79a38 Mon Sep 17 00:00:00 2001 From: dcy Date: Tue, 11 Jun 2024 15:21:25 +0800 Subject: [PATCH] inner-2396:fix delayThreshold not work properly --- .../actiontech/dble/backend/datasource/PhysicalDbInstance.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbInstance.java b/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbInstance.java index 90c5d0622..fb7390916 100644 --- a/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbInstance.java +++ b/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbInstance.java @@ -392,7 +392,7 @@ public abstract class PhysicalDbInstance implements ReadTimeStatusInstance { return false; } boolean isSync = dbSynStatus == MySQLHeartbeat.DB_SYN_NORMAL; - boolean isNotDelay = slaveBehindMaster <= this.dbGroupConfig.getDelayThreshold(); + boolean isNotDelay = slaveBehindMaster <= (this.dbGroupConfig.getDelayThreshold() / 1000); return isSync && isNotDelay; }