hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e...@apache.org
Subject git commit: HBASE-12200 When a Rpc server handler thread dies, throws exception (Alicia Ying Shu)
Date Thu, 09 Oct 2014 00:49:24 GMT
Repository: hbase
Updated Branches:
  refs/heads/master 7aa3a2d89 -> 922ced0d0


HBASE-12200 When a Rpc server handler thread dies, throws exception (Alicia Ying Shu)


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

Branch: refs/heads/master
Commit: 922ced0d0850b678705140d9bd5f9bae17f06d4a
Parents: 7aa3a2d
Author: Enis Soztutar <enis@apache.org>
Authored: Wed Oct 8 17:48:36 2014 -0700
Committer: Enis Soztutar <enis@apache.org>
Committed: Wed Oct 8 17:49:01 2014 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java    | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/922ced0d/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
index eea29ca..5fe2590 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
@@ -18,8 +18,6 @@
 
 package org.apache.hadoop.hbase.ipc;
 
-import java.io.IOException;
-
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.BlockingQueue;
@@ -29,10 +27,8 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.hbase.classification.InterfaceAudience;
 import org.apache.hadoop.hbase.classification.InterfaceStability;
-import org.apache.hadoop.conf.Configuration;
 
 import com.google.common.base.Strings;
-import com.google.common.collect.Lists;
 
 @InterfaceAudience.Private
 @InterfaceStability.Evolving
@@ -112,6 +108,9 @@ public abstract class RpcExecutor {
           try {
             activeHandlerCount.incrementAndGet();
             task.run();
+          } catch (Throwable t) {
+            LOG.error("RpcServer handler thread throws exception: ", t);
+            throw t;
           } finally {
             activeHandlerCount.decrementAndGet();
           }


Mime
View raw message