From 4af3b24b69a2db0994a4da4efa6655da0e97176e Mon Sep 17 00:00:00 2001 From: agapple Date: Tue, 8 Oct 2019 18:50:37 +0800 Subject: [PATCH] fixed issue #2281 , null reject --- .../canal/deployer/monitor/ManagerInstanceConfigMonitor.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerInstanceConfigMonitor.java b/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerInstanceConfigMonitor.java index aa9901d7..c9e99593 100644 --- a/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerInstanceConfigMonitor.java +++ b/deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerInstanceConfigMonitor.java @@ -82,6 +82,10 @@ public class ManagerInstanceConfigMonitor extends AbstractCanalLifeCycle impleme private void scan() { String instances = configClient.findInstances(null); + if (instances == null) { + return; + } + final List is = Lists.newArrayList(StringUtils.split(instances, ',')); List start = Lists.newArrayList(); List stop = Lists.newArrayList();