chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

modify

Browse Source
This commit is contained in:
machey
2018-12-30 17:16:47 +08:00
parent f9e19d46c4
commit 114c3bd020
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerRemoteConfigMonitor.java
View File

@@ -28,7 +28,7 @@ public class ManagerRemoteConfigMonitor {
private static final Logger logger = LoggerFactory.getLogger(ManagerRemoteConfigMonitor.class); private static final Logger logger = LoggerFactory.getLogger(ManagerRemoteConfigMonitor.class);
private Map<String, ConfigItem> remoteInstanceConfigs = new MapMaker().makeMap(); private Map<String, ConfigItem> remoteInstanceConfigs = new MapMaker().makeMap();
private Connection conn; private Connection conn;
private String jdbcUrl; private String jdbcUrl;
@@ -201,6 +201,7 @@ public class ManagerRemoteConfigMonitor {
for (String name : remoteInstanceConfigs.keySet()) { for (String name : remoteInstanceConfigs.keySet()) {
if (!remoteConfigStatus.containsKey(name)) { if (!remoteConfigStatus.containsKey(name)) {
// 删除 // 删除
remoteInstanceConfigs.remove(name);
removedInstanceConfig.put(name, null); removedInstanceConfig.put(name, null);
} }
} }
@@ -222,7 +223,8 @@ public class ManagerRemoteConfigMonitor {
Map<String, ConfigItem> changedInstanceConfigs = modifiedInstanceConfigs[0]; Map<String, ConfigItem> changedInstanceConfigs = modifiedInstanceConfigs[0];
if (changedInstanceConfigs != null) { if (changedInstanceConfigs != null) {
for (ConfigItem configItem : changedInstanceConfigs.values()) { 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.write(configItem.getContent());
writer.flush(); writer.flush();
} catch (Exception e) { } catch (Exception e) {