Repository: hbase Updated Branches: refs/heads/branch-1 287d08447 -> 95d290bc5
HBASE-13097 addendum use default ByteBufAllocator Signed-off-by: stack <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/95d290bc Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/95d290bc Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/95d290bc Branch: refs/heads/branch-1 Commit: 95d290bc5ebd789c24eda1793266b5976520527a Parents: 287d084 Author: zhangduo <[email protected]> Authored: Sat Feb 28 09:00:46 2015 +0800 Committer: stack <[email protected]> Committed: Fri Feb 27 17:19:32 2015 -0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/hbase/ipc/AsyncRpcClient.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/95d290bc/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AsyncRpcClient.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AsyncRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AsyncRpcClient.java index 71752f9..3bf9aad 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AsyncRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/AsyncRpcClient.java @@ -18,7 +18,6 @@ package org.apache.hadoop.hbase.ipc; import io.netty.bootstrap.Bootstrap; -import io.netty.buffer.PooledByteBufAllocator; import io.netty.channel.Channel; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; @@ -172,7 +171,6 @@ public class AsyncRpcClient extends AbstractRpcClient { this.bootstrap = new Bootstrap(); bootstrap.group(eventLoopGroupAndChannelClass.getFirst()) .channel(eventLoopGroupAndChannelClass.getSecond()) - .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT) .option(ChannelOption.TCP_NODELAY, tcpNoDelay) .option(ChannelOption.SO_KEEPALIVE, tcpKeepAlive) .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, operationTimeout);
