public class TestClientTimeouts extends Object
Modifier and Type | Class and Description |
---|---|
private static class |
TestClientTimeouts.RandomTimeoutBlockingRpcChannel
Blocking rpc channel that goes via hbase rpc.
|
private static class |
TestClientTimeouts.RandomTimeoutRpcChannel |
static class |
TestClientTimeouts.RandomTimeoutRpcClient
Rpc Channel implementation with RandomTimeoutBlockingRpcChannel
|
Modifier and Type | Field and Description |
---|---|
private static double |
CHANCE_OF_TIMEOUT |
static HBaseClassTestRule |
CLASS_RULE |
private static AtomicInteger |
invokations |
protected static int |
SLAVES |
private static HBaseTestingUtil |
TEST_UTIL |
Constructor and Description |
---|
TestClientTimeouts() |
Modifier and Type | Method and Description |
---|---|
private org.apache.hadoop.hbase.client.Connection |
createConnection() |
static void |
setUpBeforeClass() |
static void |
tearDownAfterClass() |
void |
testAdminTimeout()
Test that a client that fails an RPC to the master retries properly and doesn't throw any
unexpected exceptions.
|
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseTestingUtil TEST_UTIL
protected static int SLAVES
private static AtomicInteger invokations
private static final double CHANCE_OF_TIMEOUT
public TestClientTimeouts()
public static void setUpBeforeClass() throws Exception
Exception
public static void tearDownAfterClass() throws Exception
Exception
private org.apache.hadoop.hbase.client.Connection createConnection()
public void testAdminTimeout() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.