hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From li...@apache.org
Subject hive git commit: HIVE-16459: Forward channelInactive to RpcDispatcher (Rui reviewed by Xuefu)
Date Thu, 20 Apr 2017 03:14:50 GMT
Repository: hive
Updated Branches:
  refs/heads/master 4c9986b36 -> b0a7c131d


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


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/b0a7c131
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/b0a7c131
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/b0a7c131

Branch: refs/heads/master
Commit: b0a7c131d59b79716c3f8a8f2d3b771f6537a98e
Parents: 4c9986b
Author: Rui Li <lirui@apache.org>
Authored: Thu Apr 20 11:14:40 2017 +0800
Committer: Rui Li <lirui@apache.org>
Committed: Thu Apr 20 11:14:40 2017 +0800

----------------------------------------------------------------------
 .../src/main/java/org/apache/hive/spark/client/rpc/Rpc.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/b0a7c131/spark-client/src/main/java/org/apache/hive/spark/client/rpc/Rpc.java
----------------------------------------------------------------------
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 @@ public class Rpc implements Closeable {
     // 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);
         }
     });
   }


Mime
View raw message