Merge pull request #1440 from wurongjun/master

fix #1430

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);
     }

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) {