From d2f136ba09cb022e5a454197790014e81774587f Mon Sep 17 00:00:00 2001
From: CalvinKirs <kirs@apache.org>
Date: Wed, 13 Jan 2021 14:26:28 +0800
Subject: [PATCH] rpc

---
 .../remote/rpc/remote/NettyClientHandler.java         | 11 +++++++++--
 1 file changed, 9 insertions(+), 2 deletions(-)

diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyClientHandler.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyClientHandler.java
index 69189ca32a..76b5f313b5 100644
--- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyClientHandler.java
+++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyClientHandler.java
@@ -5,6 +5,10 @@ import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelInboundHandlerAdapter;
 
+import org.apache.dolphinscheduler.remote.utils.ChannelUtils;
+
+import java.net.InetSocketAddress;
+
 /**
  * @author jiangli
  * @date 2021-01-13 13:33
@@ -20,12 +24,15 @@ public class NettyClientHandler extends ChannelInboundHandlerAdapter {
 
     @Override
     public void channelActive(ChannelHandlerContext ctx) throws Exception {
-        super.channelActive(ctx);
+
+        ctx.channel().close();
     }
 
     @Override
     public void channelInactive(ChannelHandlerContext ctx) throws Exception {
-        super.channelInactive(ctx);
+        InetSocketAddress address =(InetSocketAddress) ctx.channel().remoteAddress();
+        ctx.channel().close();
+       //todo connectManage.removeChannel(ctx.channel());
     }
 
     @Override