From 2e1d0e36c598a3746056627b74327a57a0218ab9 Mon Sep 17 00:00:00 2001 From: mcy Date: Mon, 29 Oct 2018 01:05:12 +0800 Subject: [PATCH] =?UTF-8?q?group=20=E7=BA=BF=E7=A8=8B=E6=B1=A0=E5=9C=A8?= =?UTF-8?q?=E7=88=B6=E7=B1=BB=E5=88=9D=E5=A7=8B=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/adapter/launcher/loader/CanalAdapterWorker.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterWorker.java b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterWorker.java index 826e9ccd..198ebaae 100644 --- a/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterWorker.java +++ b/client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterWorker.java @@ -36,7 +36,6 @@ public class CanalAdapterWorker extends AbstractCanalAdapterWorker { List> canalOuterAdapters){ super(canalOuterAdapters); this.canalDestination = canalDestination; - groupInnerExecutorService = Executors.newFixedThreadPool(canalOuterAdapters.size()); connector = CanalConnectors.newSingleConnector(address, canalDestination, "", ""); } @@ -51,7 +50,6 @@ public class CanalAdapterWorker extends AbstractCanalAdapterWorker { List> canalOuterAdapters){ super(canalOuterAdapters); this.canalDestination = canalDestination; - groupInnerExecutorService = Executors.newFixedThreadPool(canalOuterAdapters.size()); connector = CanalConnectors.newClusterConnector(zookeeperHosts, canalDestination, "", ""); ((ClusterCanalConnector) connector).setSoTimeout(SO_TIMEOUT); }