From ced1741f03cf12f0afb17716d8cd1e711b078460 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 90c5d06220..fb73909163 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 @@ boolean canSelectAsReadNode() { 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; }