diff --git a/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDNPoolSingleWH.java b/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDNPoolSingleWH.java
index 9c39bc66a..91e3285cf 100644
--- a/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDNPoolSingleWH.java
+++ b/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDNPoolSingleWH.java
@@ -109,7 +109,7 @@ public class PhysicalDNPoolSingleWH extends AbstractPhysicalDBPool {
                 LOGGER.info(hostName + " " + writeSource.getName() + " init success");
             }
         }
-        if (initSuccess) {
+        if (!initSuccess) {
             LOGGER.warn(hostName + " init failure");
         }
     }
diff --git a/src/main/java/com/actiontech/dble/config/util/SchemaWriteJob.java b/src/main/java/com/actiontech/dble/config/util/SchemaWriteJob.java
index 8df4eaf9e..b02ee5ed1 100644
--- a/src/main/java/com/actiontech/dble/config/util/SchemaWriteJob.java
+++ b/src/main/java/com/actiontech/dble/config/util/SchemaWriteJob.java
@@ -50,6 +50,7 @@ public class SchemaWriteJob implements Runnable {
             errorMessage = e.getMessage();
             HaConfigManager.getInstance().log("get error from SchemaWriteJob", e);
         } finally {
+            HaConfigManager.getInstance().finishAndNext();
             this.signalAll();
         }
     }
diff --git a/src/main/java/com/actiontech/dble/singleton/HaConfigManager.java b/src/main/java/com/actiontech/dble/singleton/HaConfigManager.java
index 454c15768..fa01f9048 100644
--- a/src/main/java/com/actiontech/dble/singleton/HaConfigManager.java
+++ b/src/main/java/com/actiontech/dble/singleton/HaConfigManager.java
@@ -83,7 +83,6 @@ public final class HaConfigManager {
             } else {
                 HA_LOGGER.info("reloadId changes when try to write the local file,just skip " + reloadIndex.get());
             }
-            finishAndNext();
         } finally {
             lock.readLock().unlock();
         }