HIVE-16459: Forward channelInactive to RpcDispatcher (Rui reviewed by…

… Xuefu)
sekingme · Apr 20, 2017 · b0a7c13 · b0a7c13
1 parent 4c9986b
commit b0a7c13
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -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);
         }
     });
   }