Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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

This commit is contained in:
Enis Soztutar 2014-10-08 17:48:36 -07:00
parent 7aa3a2d890
commit 922ced0d08
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcExecutor.java
View File

@ -18,8 +18,6 @@
package org.apache.hadoop.hbase.ipc; package org.apache.hadoop.hbase.ipc;
import java.io.IOException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.concurrent.BlockingQueue; import java.util.concurrent.BlockingQueue;
@ -29,10 +27,8 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.classification.InterfaceStability; import org.apache.hadoop.hbase.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import com.google.common.base.Strings; import com.google.common.base.Strings;
import com.google.common.collect.Lists;
@InterfaceAudience.Private @InterfaceAudience.Private
@InterfaceStability.Evolving @InterfaceStability.Evolving
@ -112,6 +108,9 @@ public abstract class RpcExecutor {
try { try {
activeHandlerCount.incrementAndGet(); activeHandlerCount.incrementAndGet();
task.run(); task.run();
} catch (Throwable t) {
LOG.error("RpcServer handler thread throws exception: ", t);
throw t;
} finally { } finally {
activeHandlerCount.decrementAndGet(); activeHandlerCount.decrementAndGet();
} }