Browse Source

fixed parse instance

agapple 10 years ago
parent
commit
befc31146a

+ 2 - 1
deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java

@@ -182,7 +182,8 @@ public class CanalController {
                 public void start(String destination) {
                     InstanceConfig config = instanceConfigs.get(destination);
                     if (config == null) {
-                        config = new InstanceConfig(globalInstanceConfig);
+                        // 重新读取一下instance config
+                        config = parseInstanceConfig(properties, destination);
                         instanceConfigs.put(destination, config);
                     }