Repository: hbase Updated Branches: refs/heads/master ec877959d -> 21f12ce8e
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/21f12ce8 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/21f12ce8 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/21f12ce8 Branch: refs/heads/master Commit: 21f12ce8e5e6bc33a858f4586fe48c44b28f4a1b Parents: ec87795 Author: zhangduo <[email protected]> Authored: Sat Feb 28 09:00:46 2015 +0800 Committer: stack <[email protected]> Committed: Fri Feb 27 17:18:59 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/21f12ce8/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);
