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

Merge pull request #1540 from wurongjun/master

Browse Source 
修复当适配器mapping文件修改时，无法生效的问题
This commit is contained in:
agapple
2019-02-28 10:32:07 +08:00
committed by GitHub
parent 072420c32b ae474d67ad
commit f2368e5469
1 changed files with 169 additions and 169 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/monitor/RdbConfigMonitor.java
View File

@@ -131,8 +131,8 @@ public class RdbConfigMonitor {
rdbAdapter.getRdbMapping().put(file.getName(), mappingConfig); rdbAdapter.getRdbMapping().put(file.getName(), mappingConfig);
if (!mappingConfig.getDbMapping().getMirrorDb()) { if (!mappingConfig.getDbMapping().getMirrorDb()) {
Map<String, MappingConfig> configMap = rdbAdapter.getMappingConfigCache() Map<String, MappingConfig> configMap = rdbAdapter.getMappingConfigCache()
.computeIfAbsent(StringUtils.trimToEmpty(mappingConfig.getDestination()) + "." .computeIfAbsent(StringUtils.trimToEmpty(mappingConfig.getDestination()) + "_"
+ mappingConfig.getDbMapping().getDatabase() + "." + mappingConfig.getDbMapping().getDatabase() + "-"
+ mappingConfig.getDbMapping().getTable(), + mappingConfig.getDbMapping().getTable(),
k1 -> new HashMap<>()); k1 -> new HashMap<>());
configMap.put(file.getName(), mappingConfig); configMap.put(file.getName(), mappingConfig);