diff --git a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java b/spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java index 5dde16c..680e6b8 100644 --- a/spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java +++ b/spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java @@ -237,8 +237,9 @@ private Rpc(RpcConfiguration config, Channel channel, EventExecutorGroup egroup) // Note: this does not work for embedded channels. channel.pipeline().addLast("monitor", new ChannelInboundHandlerAdapter() { @Override - public void channelInactive(ChannelHandlerContext ctx) { + public void channelInactive(ChannelHandlerContext ctx) throws Exception { close(); + super.channelInactive(ctx); } }); }