diff --git a/src/main/java/com/actiontech/dble/backend/delyDetection/DelayDetection.java b/src/main/java/com/actiontech/dble/backend/delyDetection/DelayDetection.java index ee4283584d..be9b4bed76 100644 --- a/src/main/java/com/actiontech/dble/backend/delyDetection/DelayDetection.java +++ b/src/main/java/com/actiontech/dble/backend/delyDetection/DelayDetection.java @@ -63,6 +63,7 @@ public DelayDetection(PhysicalDbInstance source) { delayThreshold = dbGroupConfig.getDelayThreshold(); delayPeriodMillis = dbGroupConfig.getDelayPeriodMillis(); delayDetectionStatus = DelayDetectionStatus.INIT; + source.setDelayDetectionStatus(delayDetectionStatus); delayDetectionTask = new DelayDetectionTask(this); synSql(); }