From e614c6141d6a16eb0114fc029e06a52358f84926 Mon Sep 17 00:00:00 2001 From: lulu2panpan Date: Fri, 29 Apr 2016 09:28:48 +0800 Subject: [PATCH] Update ClusterCanalConnector.java --- .../alibaba/otter/canal/client/impl/ClusterCanalConnector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java b/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java index 10bcf871..cff34bb9 100644 --- a/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java +++ b/client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java @@ -45,7 +45,7 @@ public class ClusterCanalConnector implements CanalConnector { int times = 0; while (true) { try { - currentConnector = new SimpleCanalConnector(nextAddress, username, password, destination, ,accessStrategy); + currentConnector = new SimpleCanalConnector(nextAddress, username, password, destination, accessStrategy); currentConnector.setSoTimeout(soTimeout); if (filter != null) { currentConnector.setFilter(filter);