diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java
index fa16a829..efec72c6 100644
--- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java
+++ b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java
@@ -48,8 +48,8 @@ public abstract class SocketChannelPool {
             .handler(new ChannelInitializer() {
 
                 @Override
-                protected void initChannel(Channel arg0) throws Exception {
-                    arg0.pipeline().addLast(new BusinessHandler());// 命令过滤和handler添加管理
+                protected void initChannel(Channel ch) throws Exception {
+                    ch.pipeline().addLast(new BusinessHandler());// 命令过滤和handler添加管理
                 }
             });
     }
@@ -79,6 +79,7 @@ public abstract class SocketChannelPool {
         public void channelInactive(ChannelHandlerContext ctx) throws Exception {
             socket.setChannel(null);
             chManager.remove(ctx.channel());// 移除
+            super.channelInactive(ctx);
         }
 
         @Override