diff --git a/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerRemoteConfigMonitor.java b/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerRemoteConfigMonitor.java index d64cffd8..de2c3ede 100644 --- a/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerRemoteConfigMonitor.java +++ b/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerRemoteConfigMonitor.java @@ -28,7 +28,7 @@ public class ManagerRemoteConfigMonitor { private static final Logger logger = LoggerFactory.getLogger(ManagerRemoteConfigMonitor.class); - private Map remoteInstanceConfigs = new MapMaker().makeMap(); + private Map remoteInstanceConfigs = new MapMaker().makeMap(); private Connection conn; private String jdbcUrl; @@ -201,6 +201,7 @@ public class ManagerRemoteConfigMonitor { for (String name : remoteInstanceConfigs.keySet()) { if (!remoteConfigStatus.containsKey(name)) { // 删除 + remoteInstanceConfigs.remove(name); removedInstanceConfig.put(name, null); } } @@ -222,7 +223,8 @@ public class ManagerRemoteConfigMonitor { Map changedInstanceConfigs = modifiedInstanceConfigs[0]; if (changedInstanceConfigs != null) { for (ConfigItem configItem : changedInstanceConfigs.values()) { - try (FileWriter writer = new FileWriter(getConfPath() + configItem.getName() + "/instance.properties")) { + try (FileWriter writer = new FileWriter( + getConfPath() + configItem.getName() + "/instance.properties")) { writer.write(configItem.getContent()); writer.flush(); } catch (Exception e) {