diff --git a/common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java b/common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java index eea67c73..5b42683d 100644 --- a/common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java +++ b/common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java @@ -90,7 +90,7 @@ public class JsonUtils { @Override public void write(JSONSerializer serializer, Object object, Object fieldName, Type fieldType, int features) - throws IOException { + throws IOException { if (object == null) { serializer.writeNull(); return; diff --git a/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/SpringInstanceConfigMonitor.java b/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/SpringInstanceConfigMonitor.java index 0564b842..864753ab 100644 --- a/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/SpringInstanceConfigMonitor.java +++ b/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/SpringInstanceConfigMonitor.java @@ -49,7 +49,7 @@ public class SpringInstanceConfigMonitor extends AbstractCanalLifeCycle implemen private ScheduledExecutorService executor = Executors.newScheduledThreadPool(1, new NamedThreadFactory("canal-instance-scan")); - private volatile boolean isFirst = true; + private volatile boolean isFirst = true; public void start() { super.start(); @@ -60,7 +60,9 @@ public class SpringInstanceConfigMonitor extends AbstractCanalLifeCycle implemen public void run() { try { scan(); - if (isFirst) isFirst = false; + if (isFirst) { + isFirst = false; + } } catch (Throwable e) { logger.error("scan failed", e); }