You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by sy...@apache.org on 2017/03/27 20:09:07 UTC
[09/23] hbase git commit: HBASE-17798 RpcServer.Listener.Reader can
abort due to CancelledKeyException (Guangxu Cheng)
HBASE-17798 RpcServer.Listener.Reader can abort due to CancelledKeyException (Guangxu Cheng)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/1cfd22bf
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/1cfd22bf
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/1cfd22bf
Branch: refs/heads/hbase-12439
Commit: 1cfd22bf43c9b64afae35d9bf16f764d0da80cab
Parents: 8f4ae0a
Author: tedyu <yu...@gmail.com>
Authored: Tue Mar 21 06:59:29 2017 -0700
Committer: tedyu <yu...@gmail.com>
Committed: Tue Mar 21 06:59:29 2017 -0700
----------------------------------------------------------------------
.../main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/1cfd22bf/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java
index 9e1e81e..5f90d50 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java
@@ -302,7 +302,8 @@ public class SimpleRpcServer extends RpcServer {
if (running) { // unexpected -- log it
LOG.info(Thread.currentThread().getName() + " unexpectedly interrupted", e);
}
- return;
+ } catch (CancelledKeyException e) {
+ LOG.error(getName() + ": CancelledKeyException in Reader", e);
} catch (IOException ex) {
LOG.info(getName() + ": IOException in Reader", ex);
}