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 a3bb992bc..ee4283584 100644 --- a/src/main/java/com/actiontech/dble/backend/delyDetection/DelayDetection.java +++ b/src/main/java/com/actiontech/dble/backend/delyDetection/DelayDetection.java @@ -68,7 +68,7 @@ public class DelayDetection { } private void synSql() { - String[] str = {"dble", SystemConfig.getInstance().getInstanceName(), dbGroupConfig.getName()}; + String[] str = {"dble", dbGroupConfig.getName(), SystemConfig.getInstance().getInstanceName()}; sourceName = Joiner.on("_").join(str); String schema = dbGroupConfig.getDelayDatabase(); String tableName = ".u_delay "; diff --git a/src/main/java/com/actiontech/dble/services/manager/information/tables/DbleDbGroup.java b/src/main/java/com/actiontech/dble/services/manager/information/tables/DbleDbGroup.java index bac1b960c..b3cbb6140 100644 --- a/src/main/java/com/actiontech/dble/services/manager/information/tables/DbleDbGroup.java +++ b/src/main/java/com/actiontech/dble/services/manager/information/tables/DbleDbGroup.java @@ -105,10 +105,16 @@ public class DbleDbGroup extends ManagerWritableTable { map.put(COLUMN_ACTIVE, Boolean.TRUE.toString()); return map; }).collect(Collectors.toList()); + tempRowList.forEach(this::defaultVal); rowList.addAll(tempRowList); return rowList; } + private void defaultVal(LinkedHashMap rows) { + String delayDatabase = rows.get(DELAY_DATABASE); + rows.put(DELAY_DATABASE, String.valueOf(delayDatabase)); + } + @Override public int insertRows(List> rows) { //check rule