You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ap...@apache.org on 2017/11/14 02:21:38 UTC
[3/9] hbase git commit: HBASE-19215 Incorrect exception handling on
the client causes incorrect call timeouts and byte buffer allocations on the
server
HBASE-19215 Incorrect exception handling on the client causes incorrect call timeouts and byte buffer allocations on the server
Signed-off-by: Andrew Purtell <ap...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/96b86b71
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/96b86b71
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/96b86b71
Branch: refs/heads/branch-1
Commit: 96b86b71d2f32f842e9ed57341ee3d7f4e8329f6
Parents: 45116c8
Author: Abhishek Singh Chouhan <ac...@apache.org>
Authored: Mon Nov 13 17:16:31 2017 +0530
Committer: Andrew Purtell <ap...@apache.org>
Committed: Mon Nov 13 16:59:48 2017 -0800
----------------------------------------------------------------------
.../org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/96b86b71/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java
index 6645694..d5cf6a2 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java
@@ -551,7 +551,11 @@ class BlockingRpcConnection extends RpcConnection implements Runnable {
// pending calls map.
try {
call.callStats.setRequestSizeBytes(write(this.out, requestHeader, call.param, cellBlock));
- } catch (IOException e) {
+ } catch (Throwable t) {
+ if(LOG.isTraceEnabled()) {
+ LOG.trace("Error while writing call, call_id:" + call.id, t);
+ }
+ IOException e = IPCUtil.toIOE(t);
closeConn(e);
return;
}