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

HBASE-13514 Fix test failures in TestScannerHeartbeatMessages caused by incorrect setting of hbase.rpc.timeout (Jonathan Lawlor)

This commit is contained in:
tedyu 2015-04-20 14:48:10 -07:00
parent 702aea5b38
commit eb82b8b309
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScannerHeartbeatMessages.java
View File

@ -104,7 +104,7 @@ public class TestScannerHeartbeatMessages {
// Time, in milliseconds, that the client will wait for a response from the server before timing // Time, in milliseconds, that the client will wait for a response from the server before timing
// out. This value is used server side to determine when it is necessary to send a heartbeat // out. This value is used server side to determine when it is necessary to send a heartbeat
// message to the client // message to the client
private static int CLIENT_TIMEOUT = 500; private static int CLIENT_TIMEOUT = 2000;
// The server limits itself to running for half of the CLIENT_TIMEOUT value. // The server limits itself to running for half of the CLIENT_TIMEOUT value.
private static int SERVER_TIME_LIMIT = CLIENT_TIMEOUT / 2; private static int SERVER_TIME_LIMIT = CLIENT_TIMEOUT / 2;
@ -113,7 +113,7 @@ public class TestScannerHeartbeatMessages {
private static int DEFAULT_ROW_SLEEP_TIME = SERVER_TIME_LIMIT / 2; private static int DEFAULT_ROW_SLEEP_TIME = SERVER_TIME_LIMIT / 2;
// By default, at most cells for two column families are retrieved before the time limit is // By default, at most cells for two column families are retrieved before the time limit is
// reached // reached
private static int DEFAULT_CF_SLEEP_TIME = SERVER_TIME_LIMIT / 2; private static int DEFAULT_CF_SLEEP_TIME = DEFAULT_ROW_SLEEP_TIME / NUM_FAMILIES;
@BeforeClass @BeforeClass
public static void setUpBeforeClass() throws Exception { public static void setUpBeforeClass() throws Exception {
@ -173,6 +173,7 @@ public class TestScannerHeartbeatMessages {
@AfterClass @AfterClass
public static void tearDownAfterClass() throws Exception { public static void tearDownAfterClass() throws Exception {
TEST_UTIL.deleteTable(TABLE_NAME);
TEST_UTIL.shutdownMiniCluster(); TEST_UTIL.shutdownMiniCluster();
} }