From bb64d842983f6051e2a12992278ec3f257d6e1ef Mon Sep 17 00:00:00 2001 From: "wurongjun@duiba.com.cn" <775105396@qq.com> Date: Tue, 29 Jan 2019 16:10:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=BB=8E=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93=E5=8A=A0=E8=BD=BD=E9=85=8D=E7=BD=AE=E5=86=99=E5=85=A5?= =?UTF-8?q?=E6=96=87=E4=BB=B6=E6=97=B6=E5=9B=A0=E7=9B=AE=E5=BD=95=E4=B8=8D?= =?UTF-8?q?=E5=AD=98=E5=9C=A8=E5=87=BA=E7=8E=B0=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../monitor/remote/DbRemoteConfigLoader.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/DbRemoteConfigLoader.java b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/DbRemoteConfigLoader.java index 824ddcc9..704a606f 100644 --- a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/DbRemoteConfigLoader.java +++ b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/DbRemoteConfigLoader.java @@ -290,11 +290,22 @@ public class DbRemoteConfigLoader implements RemoteConfigLoader { @Override public void onModify(ConfigItem configItem) { + String confPath = getConfPath(); + String category = configItem.getCategory(); + File categoryDir = new File(confPath + category); + if (!categoryDir.isDirectory()) { + boolean mkDirs = categoryDir.mkdirs(); + if (!mkDirs) { + logger.info("## Create adapter category dir error: {}", category); + return; + } + } + String name = configItem.getName(); try (FileWriter writer = new FileWriter( - getConfPath() + configItem.getCategory() + "/" + configItem.getName())) { + confPath + category + "/" + configItem.getName())) { writer.write(configItem.getContent()); writer.flush(); - logger.info("## Loaded remote adapter config: {}/{}", configItem.getCategory(), configItem.getName()); + logger.info("## Loaded remote adapter config: {}/{}", category, name); } catch (Exception e) { logger.error(e.getMessage(), e); }