diff --git a/client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/monitor/HbaseConfigMonitor.java b/client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/monitor/HbaseConfigMonitor.java index da16ee2e..803bbe1c 100644 --- a/client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/monitor/HbaseConfigMonitor.java +++ b/client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/monitor/HbaseConfigMonitor.java @@ -60,10 +60,6 @@ public class HbaseConfigMonitor { try { // 加载新增的配置文件 String configContent = MappingConfigsLoader.loadConfig(adapterName + File.separator + file.getName()); - if (configContent == null) { - onFileDelete(file); - return; - } MappingConfig config = new Yaml().loadAs(configContent, MappingConfig.class); config.validate(); addConfigToCache(file, config); @@ -83,6 +79,10 @@ public class HbaseConfigMonitor { // 加载配置文件 String configContent = MappingConfigsLoader .loadConfig(adapterName + File.separator + file.getName()); + if (configContent == null) { + onFileDelete(file); + return; + } MappingConfig config = new Yaml().loadAs(configContent, MappingConfig.class); config.validate(); if (hbaseAdapter.getHbaseMapping().containsKey(file.getName())) {