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

HBASE-19323 Make netty engine default in hbase2

This commit is contained in:
Michael Stack 2017-11-21 20:16:55 -08:00
parent 30ca85d21f
commit ed60e4518d
No known key found for this signature in database
GPG Key ID: 9816C7FC8ACC93D2
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServerFactory.java
View File

@ -48,7 +48,7 @@ public class RpcServerFactory {
final InetSocketAddress bindAddress, Configuration conf, final InetSocketAddress bindAddress, Configuration conf,
RpcScheduler scheduler) throws IOException { RpcScheduler scheduler) throws IOException {
String rpcServerClass = conf.get(CUSTOM_RPC_SERVER_IMPL_CONF_KEY, String rpcServerClass = conf.get(CUSTOM_RPC_SERVER_IMPL_CONF_KEY,
SimpleRpcServer.class.getName()); NettyRpcServer.class.getName());
StringBuffer servicesList = new StringBuffer(); StringBuffer servicesList = new StringBuffer();
for (BlockingServiceAndInterface s: services) { for (BlockingServiceAndInterface s: services) {
ServiceDescriptor sd = s.getBlockingService().getDescriptorForType(); ServiceDescriptor sd = s.getBlockingService().getDescriptorForType();

5
hbase-server/src/test/java/org/apache/hadoop/hbase/ipc/AbstractTestIPC.java
View File

@ -59,6 +59,7 @@ import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;
import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.io.compress.GzipCodec; import org.apache.hadoop.io.compress.GzipCodec;
import org.apache.hadoop.util.StringUtils; import org.apache.hadoop.util.StringUtils;
import org.junit.BeforeClass;
import org.junit.Test; import org.junit.Test;
import org.apache.hadoop.hbase.shaded.com.google.common.collect.ImmutableList; import org.apache.hadoop.hbase.shaded.com.google.common.collect.ImmutableList;
@ -75,6 +76,10 @@ public abstract class AbstractTestIPC {
private static final KeyValue CELL = new KeyValue(CELL_BYTES, CELL_BYTES, CELL_BYTES, CELL_BYTES); private static final KeyValue CELL = new KeyValue(CELL_BYTES, CELL_BYTES, CELL_BYTES, CELL_BYTES);
protected static final Configuration CONF = HBaseConfiguration.create(); protected static final Configuration CONF = HBaseConfiguration.create();
static {
// Set the default to be the old SimpleRpcServer. Subclasses test it and netty.
CONF.set(RpcServerFactory.CUSTOM_RPC_SERVER_IMPL_CONF_KEY, SimpleRpcServer.class.getName());
}
protected abstract RpcServer createRpcServer(final Server server, final String name, protected abstract RpcServer createRpcServer(final Server server, final String name,
final List<BlockingServiceAndInterface> services, final List<BlockingServiceAndInterface> services,