diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ClientCache.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ClientCache.java index f33f59c..4dcc2d1 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ClientCache.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ClientCache.java @@ -27,8 +27,6 @@ import javax.net.SocketFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HConstants; -import org.apache.hadoop.hbase.io.HbaseObjectWritable; -import org.apache.hadoop.io.Writable; /** * Cache a client using its socket factory as the hash key. @@ -101,4 +99,4 @@ class ClientCache { client.stop(); } } -} +} \ No newline at end of file diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/HBaseClient.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/HBaseClient.java index fb59bea..a8a799e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/HBaseClient.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/HBaseClient.java @@ -1317,7 +1317,6 @@ public class HBaseClient { * @param exception the relevant exception * @return an exception to throw */ - @SuppressWarnings({"ThrowableInstanceNeverThrown"}) protected IOException wrapException(InetSocketAddress addr, IOException exception) { if (exception instanceof ConnectException) { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MasterCoprocessorRpcChannel.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MasterCoprocessorRpcChannel.java index b3a4228..6971b34 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MasterCoprocessorRpcChannel.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MasterCoprocessorRpcChannel.java @@ -18,26 +18,20 @@ package org.apache.hadoop.hbase.ipc; -import com.google.protobuf.BlockingRpcChannel; -import com.google.protobuf.ByteString; -import com.google.protobuf.Descriptors; -import com.google.protobuf.Message; -import com.google.protobuf.RpcCallback; -import com.google.protobuf.RpcChannel; -import com.google.protobuf.RpcController; -import com.google.protobuf.ServiceException; +import java.io.IOException; + import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.client.HConnection; import org.apache.hadoop.hbase.protobuf.ProtobufUtil; -import org.apache.hadoop.hbase.protobuf.ResponseConverter; import org.apache.hadoop.hbase.protobuf.generated.ClientProtos; +import org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceResponse; -import java.io.IOException; - -import static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.CoprocessorServiceResponse; +import com.google.protobuf.ByteString; +import com.google.protobuf.Descriptors; +import com.google.protobuf.Message; /** * Provides clients with an RPC connection to call coprocessor endpoint {@link com.google.protobuf.Service}s diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServer.java index 8e33c1d..a8e605e 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/MetricsHBaseServer.java @@ -26,7 +26,6 @@ import org.apache.hadoop.hbase.CompatibilitySingletonFactory; @InterfaceAudience.Private public class MetricsHBaseServer { - private static Log LOG = LogFactory.getLog(MetricsHBaseServer.class); private MetricsHBaseServerSource source; public MetricsHBaseServer(String serverName, MetricsHBaseServerWrapper wrapper) { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ProtobufRpcEngine.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ProtobufRpcEngine.java index 9a5196a..6edc788 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ProtobufRpcEngine.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/ProtobufRpcEngine.java @@ -224,9 +224,6 @@ class ProtobufRpcEngine implements RpcEngine { private static final int DEFAULT_WARN_RESPONSE_TIME = 10000; // milliseconds private static final int DEFAULT_WARN_RESPONSE_SIZE = 100 * 1024 * 1024; - /** Names for suffixed metrics */ - private static final String ABOVE_ONE_SEC_METRIC = ".aboveOneSec."; - private final int warnResponseTime; private final int warnResponseSize; diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java index 50883e9..dd893a4 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcServer.java @@ -29,8 +29,6 @@ import org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RpcRequestBody; import java.io.IOException; import java.net.InetSocketAddress; -/** - */ @InterfaceAudience.Private public interface RpcServer {