From 70e6bdde02288cccbebdb51c0bc52898c6c8ee1a Mon Sep 17 00:00:00 2001
From: spccold <wenK712@gmail.com>
Date: Sat, 5 May 2018 11:35:41 +0800
Subject: [PATCH] close zkclientx if necessary when stop canal

---
 .../com/alibaba/otter/canal/deployer/CanalController.java     | 4 ++++
 1 file changed, 4 insertions(+)

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 9bf42bf1..08c0744d 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
@@ -454,6 +454,10 @@ public class CanalController {
         // 释放canal的工作节点
         releaseCid(ZookeeperPathUtils.getCanalClusterNode(ip + ":" + port));
         logger.info("## stop the canal server[{}:{}]", ip, port);
+        
+        if (zkclientx != null) {
+            zkclientx.close();
+        }
     }
 
     private void initCid(String path) {