mirror of
https://github.com/actiontech/dble.git
synced 2026-05-19 22:30:15 -05:00
This commit is contained in:
@@ -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");
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user