From 47d791430487d4323e213a61aaa88762d177ec5b Mon Sep 17 00:00:00 2001
From: "wurongjun@duiba.com.cn" <775105396@qq.com>
Date: Wed, 16 Jan 2019 17:28:51 +0800
Subject: [PATCH] =?UTF-8?q?=E5=81=9C=E6=9C=BA=E6=97=B6=E6=B8=85=E7=A9=BAzk?=
 =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E4=BF=A1=E6=81=AF=EF=BC=8C=E4=BF=AE?=
 =?UTF-8?q?=E5=A4=8D=E9=87=8D=E5=90=AF=E6=97=B6=E6=8A=A5=E5=87=BA=E7=9A=84?=
 =?UTF-8?q?zk=E8=BF=9E=E6=8E=A5=E5=B7=B2=E5=85=B3=E9=97=AD=E7=9A=84?=
 =?UTF-8?q?=E5=BC=82=E5=B8=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/alibaba/otter/canal/common/zookeeper/ZkClientx.java   | 4 ++++
 .../com/alibaba/otter/canal/deployer/CanalController.java     | 2 ++
 2 files changed, 6 insertions(+)

diff --git a/common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ZkClientx.java b/common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ZkClientx.java
index 76255bd1..450c0569 100644
--- a/common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ZkClientx.java
+++ b/common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ZkClientx.java
@@ -34,6 +34,10 @@ public class ZkClientx extends ZkClient {
         return clients.get(servers);
     }
 
+    public static void clearClients() {
+        clients.clear();
+    }
+
     public ZkClientx(String serverstring){
         this(serverstring, Integer.MAX_VALUE);
     }
diff --git a/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java b/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java
index dbc5938e..8d4ac714 100644
--- a/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java
+++ b/deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java
@@ -503,6 +503,8 @@ public class CanalController {
         if (zkclientx != null) {
             zkclientx.close();
         }
+
+        ZkClientx.clearClients();
     }
 
     private void initCid(String path) {