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

[lirui]

Repository: hive
Updated Branches:
  refs/heads/branch-2.3 228629df7 -> 94ea7f514


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/94ea7f51
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/94ea7f51
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/94ea7f51

Branch: refs/heads/branch-2.3
Commit: 94ea7f514dd30475334d8d6c1a972abc2bd0110d
Parents: 228629d
Author: Rui Li 
Authored: Thu Apr 20 11:14:40 2017 +0800
Committer: Rui Li 
Committed: Thu Apr 20 11:19:51 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/94ea7f51/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);
 }
 });
   }

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

[lirui]

Repository: hive
Updated Branches:
  refs/heads/branch-2 cce0734de -> 45c53aced


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/45c53ace
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/45c53ace
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/45c53ace

Branch: refs/heads/branch-2
Commit: 45c53aced512a139bb63bf1b20a33e345668ff7e
Parents: cce0734
Author: Rui Li 
Authored: Thu Apr 20 11:14:40 2017 +0800
Committer: Rui Li 
Committed: Thu Apr 20 11:19:02 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/45c53ace/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);
 }
 });
   }