You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by li...@apache.org on 2017/04/20 03:14:50 UTC
hive git commit: HIVE-16459: Forward channelInactive to RpcDispatcher
(Rui reviewed by Xuefu)
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 <li...@apache.org>
Authored: Thu Apr 20 11:14:40 2017 +0800
Committer: Rui Li <li...@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);
}
});
}